Fix string xcom (should be a list)

luabida · luabida · commit 7678fc0c1eb4 · 2023-05-29T08:47:26.000-03:00
diff --git a/containers/airflow/dags/brasil/sinan.py b/containers/airflow/dags/brasil/sinan.py
@@ -155,9 +155,9 @@ def extract_parquets(**kwargs) -> dict:
         )
 
         return dict(
-            pqs_to_insert=extract_pqs('to_insert'),
-            pqs_to_finals=extract_pqs('to_finals'),
-            pqs_to_update=extract_pqs('to_update'),
+            pqs_to_insert=list(extract_pqs('to_insert')),
+            pqs_to_finals=list(extract_pqs('to_finals')),
+            pqs_to_update=list(extract_pqs('to_update')),
         )
 
     @task(task_id='first_insertion', trigger_rule='all_done')

Original file line number	Diff line number	Diff line change
`@@ -155,9 +155,9 @@ def extract_parquets(**kwargs) -> dict:`
`155`	`155`	`)`
`156`	`156`
`157`	`157`	`return dict(`
`158`		`- pqs_to_insert=extract_pqs('to_insert'),`
`159`		`- pqs_to_finals=extract_pqs('to_finals'),`
`160`		`- pqs_to_update=extract_pqs('to_update'),`
	`158`	`+ pqs_to_insert=list(extract_pqs('to_insert')),`
	`159`	`+ pqs_to_finals=list(extract_pqs('to_finals')),`
	`160`	`+ pqs_to_update=list(extract_pqs('to_update')),`
`161`	`161`	`)`
`162`	`162`
`163`	`163`	`@task(task_id='first_insertion', trigger_rule='all_done')`