We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 365049e commit c222580Copy full SHA for c222580
airflow/dags/polygonetl_airflow/build_export_dag.py
@@ -7,7 +7,7 @@
7
from tempfile import TemporaryDirectory
8
9
from airflow import DAG, configuration
10
-from airflow.operators.dummy import DummyOperator
+from airflow.operators.empty import EmptyOperator
11
from airflow.operators.python import PythonOperator
12
13
from polygonetl.cli import (
@@ -345,7 +345,7 @@ def add_export_task(
345
return None
346
347
# Operators
348
- export_complete = DummyOperator(task_id="export_complete", dag=dag)
+ export_complete = EmptyOperator(task_id="export_complete", dag=dag)
349
350
export_blocks_and_transactions_operator = add_export_task(
351
export_blocks_and_transactions_toggle,
0 commit comments