diff --git a/dag_load_inlabs/ro-dou_inlabs_load_pg_dag.py b/dag_load_inlabs/ro-dou_inlabs_load_pg_dag.py index 5c76112..8314408 100644 --- a/dag_load_inlabs/ro-dou_inlabs_load_pg_dag.py +++ b/dag_load_inlabs/ro-dou_inlabs_load_pg_dag.py @@ -212,7 +212,6 @@ def _clean_db(hook: PostgresHook): WHERE DATE(pubdate) = '{{{{ ti.xcom_pull(task_ids='get_date')}}}}' """, - outlets=[Dataset("inlabs")] ) @task.branch