9191%nonterm csv_data logic.CSVData
9292%nonterm csv_locator_inline_data String
9393%nonterm csv_locator_paths Sequence[String]
94- %nonterm storage_integration Sequence[Tuple[String, logic.Value]]
94+ %nonterm _storage_integration Sequence[Tuple[String, logic.Value]]
9595%nonterm csvlocator logic.CSVLocator
9696%nonterm data logic.Data
9797%nonterm date logic.DateValue
217217%validator_ignore_completeness BeTreeLocator
218218%validator_ignore_completeness BeTreeConfig
219219%validator_ignore_completeness ExportCSVColumns
220- %validator_ignore_completeness CSVStorageIntegration
220+ %validator_ignore_completeness StorageIntegration
221221
222222%%
223223
@@ -1129,13 +1129,13 @@ csvlocator
11291129 $4 : Optional[String] = builtin.decode_string($$.inline_data) if builtin.decode_string($$.inline_data) != " " else None
11301130
11311131csv_config
1132- : " (" " csv_config" config_dict storage_integration ? " )"
1132+ : " (" " csv_config" config_dict _storage_integration ? " )"
11331133 construct: $$ = construct_csv_config($3 , $4 )
11341134 deconstruct:
11351135 $3 : Sequence[Tuple[String, logic.Value]] = deconstruct_csv_config($$)
11361136 $4 : Optional[Sequence[Tuple[String, logic.Value]]] = deconstruct_csv_storage_integration_optional($$)
11371137
1138- storage_integration
1138+ _storage_integration
11391139 : " (" " storage_integration" config_dict " )"
11401140 construct: $$ = $3
11411141 deconstruct: $3 : Sequence[Tuple[String, logic.Value]] = $$
@@ -1490,7 +1490,7 @@ def construct_csv_config(
14901490 encoding: str = _extract_value_string(builtin.dict_get(config, " csv_encoding" ), "utf-8")
14911491 compression: str = _extract_value_string(builtin.dict_get(config, " csv_compression" ), "auto")
14921492 partition_size_mb: int = _extract_value_int64(builtin.dict_get(config, " csv_partition_size_mb" ), 0)
1493- storage_integration: Optional[logic.CSVStorageIntegration ] = construct_csv_storage_integration(storage_integration_opt)
1493+ storage_integration: Optional[logic.StorageIntegration ] = construct_csv_storage_integration(storage_integration_opt)
14941494 return logic.CSVConfig(
14951495 header_row=header_row,
14961496 skip=skip,
@@ -1510,11 +1510,11 @@ def construct_csv_config(
15101510
15111511def construct_csv_storage_integration(
15121512 storage_integration_opt: Optional[Sequence[Tuple[String, logic.Value]]],
1513- ) -> Optional[logic.CSVStorageIntegration ]:
1513+ ) -> Optional[logic.StorageIntegration ]:
15141514 if storage_integration_opt is None:
15151515 return builtin.none()
15161516 config: Dict[String, logic.Value] = builtin.dict_from_list(builtin.unwrap_option(storage_integration_opt))
1517- return builtin.some(logic.CSVStorageIntegration (
1517+ return builtin.some(logic.StorageIntegration (
15181518 provider=_extract_value_string(builtin.dict_get(config, " provider" ), ""),
15191519 azure_sas_token=_extract_value_string(builtin.dict_get(config, " azure_sas_token" ), ""),
15201520 s3_region=_extract_value_string(builtin.dict_get(config, " s3_region" ), ""),
@@ -1692,7 +1692,7 @@ def deconstruct_csv_config(msg: logic.CSVConfig) -> List[Tuple[String, logic.Val
16921692def deconstruct_csv_storage_integration_optional (msg: logic.CSVConfig) -> Optional[Sequence[Tuple[String, logic.Value]]]:
16931693 if not builtin.has_proto_field(msg, " storage_integration" ):
16941694 return builtin.none()
1695- si: logic.CSVStorageIntegration = builtin.unwrap_option(msg.storage_integration)
1695+ si: logic.StorageIntegration = builtin.unwrap_option(msg.storage_integration)
16961696 result: List[Tuple[String, logic.Value]] = list[Tuple[String, logic.Value]]()
16971697 if si.provider != "":
16981698 builtin.list_push(result, builtin.tuple(" provider" , _make_value_string(si.provider)))
0 commit comments