Skip to content
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.

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

fix(interactive): Add data_source in schema_mapping #3953

Merged
merged 8 commits into from
Jun 20, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
11 changes: 7 additions & 4 deletions flex/interactive/sdk/python/test/test_driver.py
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,9 @@
from gs_interactive.models.schema_mapping_loading_config_format import (
SchemaMappingLoadingConfigFormat,
)
from gs_interactive.models.schema_mapping_loading_config_data_source import (
SchemaMappingLoadingConfigDataSource,
)
from gs_interactive.models.start_service_request import StartServiceRequest
from gs_interactive.models.string_type import StringType
from gs_interactive.models.string_type_string import StringTypeString
Expand Down Expand Up @@ -156,13 +159,13 @@ def createGraph(self):

def bulkLoading(self):
assert os.environ.get("FLEX_DATA_DIR") is not None
person_csv_path = os.path.join(os.environ.get("FLEX_DATA_DIR"), "person.csv")
knows_csv_path = os.path.join(
os.environ.get("FLEX_DATA_DIR"), "person_knows_person.csv"
)
location = os.environ.get("FLEX_DATA_DIR")
person_csv_path = "person.csv"
knows_csv_path = "person_knows_person.csv"
print("test bulk loading: ", self._graph_id)
schema_mapping = SchemaMapping(
loading_config=SchemaMappingLoadingConfig(
data_source=SchemaMappingLoadingConfigDataSource(scheme="file", location=location),
import_option="init",
format=SchemaMappingLoadingConfigFormat(type="csv"),
),
Expand Down
10 changes: 10 additions & 0 deletions flex/openapi/openapi_interactive.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -1568,6 +1568,16 @@ components:
loading_config:
type: object
properties:
data_source:
type: object
properties:
scheme:
type: string
enum:
- odps
- file
location:
type: string
import_option:
type: string
enum:
Expand Down
Loading