Skip to content

fix: Add stream feature view in the Web UI #3257

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
feast-ci-bot merged 8 commits into from
Sep 30, 2022
Merged

fix: Add stream feature view in the Web UI #3257

Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
f94d088
add stream feature view to ui
hao-affirm Sep 27, 2022
5fb4833
update source
hao-affirm Sep 27, 2022
32384f3
update example
hao-affirm Sep 27, 2022
a0ef748
add registry
hao-affirm Sep 27, 2022
d91be15
fix lint
hao-affirm Sep 27, 2022
fb137cc
fix bug
hao-affirm Sep 28, 2022
9478b10
add batch source
hao-affirm Sep 29, 2022
ab2d8c8
fix warning
hao-affirm Sep 29, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
update source 
Signed-off-by: hao-affirm <104030690+hao-affirm@users.noreply.github.com>
  • Loading branch information
@hao-affirm
hao-affirm committed Sep 27, 2022
commit 5fb4833a4c94f0f27d3c4df9421c6a74ac240d45
41 changes: 5 additions & 36 deletions ui/src/parsers/feastSFVS.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,18 +8,8 @@ const FeatureViewProjectionSchema = z.object({
}),
});

const RequestDataSourceSchema = z.object({
requestDataSource: z.object({
type: z.string(),
name: z.string(),
requestDataOptions: z.object({
schema: z.array(FeastFeatureColumnSchema),
}),
}),
});

const StreamDataSourceSchema = z.object({
streamDataSource: z.object({
const StreamSourceSchema = z.object({
streamSource: z.object({
type: z.string(),
name: z.string(),
streamDataOptions: z.object({
Expand All @@ -28,32 +18,11 @@ const StreamDataSourceSchema = z.object({
}),
});

const ODFVInputsSchema = z.union([
FeatureViewProjectionSchema,
StreamDataSourceSchema,
]);

const SFVInputsSchema = z.union([
FeatureViewProjectionSchema,
StreamDataSourceSchema,
StreamSourceSchema,
]);

const FeastODFVSchema = z.object({
spec: z.object({
name: z.string(),
features: z.array(FeastFeatureColumnSchema),
sources: z.record(ODFVInputsSchema),
userDefinedFunction: z.object({
name: z.string(),
body: z.string(),
}),
}),
meta: z.object({
createdTimestamp: z.string().transform((val) => new Date(val)),
lastUpdatedTimestamp: z.string().transform((val) => new Date(val)),
}),
});

const FeastSFVSchema = z.object({
spec: z.object({
name: z.string(),
Expand All @@ -71,7 +40,7 @@ const FeastSFVSchema = z.object({
});

type FeastSFVType = z.infer<typeof FeastSFVSchema>;
type StreamDataSourceType = z.infer<typeof StreamDataSourceSchema>;
type StreamSourceType = z.infer<typeof StreamSourceSchema>;

export { FeastSFVSchema };
export type { FeastSFVType, StreamDataSourceType};
export type { FeastSFVType, StreamSourceType};