Ash Berlin-Taylor

icon indicating an email [email protected]

icon company Astronomer.io icon location London icon location PMC @ Apache Airflow, Airflow Engineering Director @ Astronomer.io

Results 323 comments of Ash Berlin-Taylor

ImportError: cannot import name 'SUPERVISOR_COMMS' with dag.test()

Assuming we can detect the case when this is being imported from doing `python mydag.py` (which I'm 95% sure we can, so that is the 'easy' part) how should we...

ImportError: cannot import name 'SUPERVISOR_COMMS' with dag.test()

So: detecting when we have top-level dag code, at least in the `python mydagfile.py` case: ```python def __getattr__(name): if name == "SUPERVISOR_COMMS" and "__main__" in sys.modules: import traceback frames =...

ImportError: cannot import name 'SUPERVISOR_COMMS' with dag.test()

> UPD: import `Variable` from `airflow.models` instead of `airflow.sdk` fixes the problem but doesn't seem like a best practice solution. Yeah, that still works as it's falling back to the...