File tree Expand file tree Collapse file tree 1 file changed +2
-6
lines changed
src/sagemaker/feature_store Expand file tree Collapse file tree 1 file changed +2
-6
lines changed Original file line number Diff line number Diff line change @@ -438,17 +438,13 @@ def to_csv_file(self) -> Tuple[str, str]:
438438 os .remove (local_file_name )
439439 temp_table_name = f'dataframe_{ temp_id .replace ("-" , "_" )} '
440440 self ._create_temp_table (temp_table_name , desired_s3_folder )
441- query_result = self ._run_query (
442- ** self ._to_athena_query (temp_table_name = temp_table_name )
443- )
441+ query_result = self ._run_query (** self ._to_athena_query (temp_table_name = temp_table_name ))
444442 # TODO: cleanup temp table, need more clarification, keep it for now
445443 return query_result .get ("QueryExecution" , {}).get ("ResultConfiguration" , {}).get (
446444 "OutputLocation" , None
447445 ), query_result .get ("QueryExecution" , {}).get ("Query" , None )
448446 if isinstance (self ._base , FeatureGroup ):
449- query_result = self ._run_query (
450- ** self ._to_athena_query ()
451- )
447+ query_result = self ._run_query (** self ._to_athena_query ())
452448 return query_result .get ("QueryExecution" , {}).get ("ResultConfiguration" , {}).get (
453449 "OutputLocation" , None
454450 ), query_result .get ("QueryExecution" , {}).get ("Query" , None )
You can’t perform that action at this time.
0 commit comments