hub / github.com/dlt-hub/dlt / is_running_in_airflow_task

Function is_running_in_airflow_task

dlt/common/runtime/exec_info.py:170–171 · view source on GitHub ↗

()

Source from the content-addressed store, hash-verified

168
169
170	def is_running_in_airflow_task() -> bool:
171	return "AIRFLOW_CTX_TASK_ID" in os.environ
172
173
174	def is_running_in_dagster_task() -> bool:

_r_initFunction · 0.90

test_run_decomposed_with_state_wipeFunction · 0.90

dag_regularFunction · 0.90

exec_info_namesFunction · 0.85

no outgoing calls

_r_initFunction · 0.72

test_run_decomposed_with_state_wipeFunction · 0.72

dag_regularFunction · 0.72