update the code to make sure loop is correct

linglp · linglp · commit 7168053996b0 · 2025-12-23T21:45:47.000Z
diff --git a/dags/synapse_minimal_jsonld_dag.py b/dags/synapse_minimal_jsonld_dag.py
@@ -290,8 +290,8 @@ def create_and_push_to_s3(**context) -> None:
                 "license": "" if pd.isnull(row["license"]) else row["license"]
             }
 
-        s3_key = f"{dataset_name}_{dataset_id}.minimal_croissant.jsonld"
-        execute_push_to_s3(dataset=dataset,dataset_id=row["id"],s3_key=s3_key, croissant_file=minimal_croissant_file, push_to_s3=push_to_s3, **context)
+            s3_key = f"{dataset_name}_{dataset_id}.minimal_croissant.jsonld"
+            execute_push_to_s3(dataset=dataset,dataset_id=row["id"],s3_key=s3_key, croissant_file=minimal_croissant_file, push_to_s3=push_to_s3, **context)
 
 
     create_and_push_to_s3()

Original file line number	Diff line number	Diff line change
`@@ -290,8 +290,8 @@ def create_and_push_to_s3(**context) -> None:`
`290`	`290`	`"license": "" if pd.isnull(row["license"]) else row["license"]`
`291`	`291`	`}`
`292`	`292`
`293`		`- s3_key = f"{dataset_name}_{dataset_id}.minimal_croissant.jsonld"`
`294`		`- execute_push_to_s3(dataset=dataset,dataset_id=row["id"],s3_key=s3_key, croissant_file=minimal_croissant_file, push_to_s3=push_to_s3, **context)`
	`293`	`+ s3_key = f"{dataset_name}_{dataset_id}.minimal_croissant.jsonld"`
	`294`	`+ execute_push_to_s3(dataset=dataset,dataset_id=row["id"],s3_key=s3_key, croissant_file=minimal_croissant_file, push_to_s3=push_to_s3, **context)`
`295`	`295`
`296`	`296`
`297`	`297`	`create_and_push_to_s3()`