ephraimbuddy commented on issue #18114:
URL: https://github.com/apache/airflow/issues/18114#issuecomment-918090551
I will be taking a look. Just got a slightly different error from it now in
main:
```log
[2021-09-13 11:06:29,061] {dagbag.py:205} WARNING - Serialized DAG
employees_etl no longer exists
[2021-09-13 11:06:29,061] {scheduler_job.py:942} ERROR - Couldn't find dag
employees_etl in DagBag/DB!
[2021-09-13 11:06:29,111] {scheduler_job.py:584} ERROR - Exception when
executing SchedulerJob._run_scheduler_loop
Traceback (most recent call last):
File "/opt/airflow/airflow/jobs/scheduler_job.py", line 568, in _execute
self._run_scheduler_loop()
File "/opt/airflow/airflow/jobs/scheduler_job.py", line 649, in
_run_scheduler_loop
num_queued_tis = self._do_scheduling(session)
File "/opt/airflow/airflow/jobs/scheduler_job.py", line 749, in
_do_scheduling
self._send_dag_callbacks_to_processor(dag_run, callback_to_run)
File "/opt/airflow/airflow/jobs/scheduler_job.py", line 1014, in
_send_dag_callbacks_to_processor
dag = dag_run.get_dag()
File "/opt/airflow/airflow/models/dagrun.py", line 395, in get_dag
raise AirflowException(f"The DAG (.dag) for {self} needs to be set")
airflow.exceptions.AirflowException: The DAG (.dag) for <DagRun
employees_etl @ 2021-07-12 16:00:00+00:00:
scheduled__2021-07-12T16:00:00+00:00, externally triggered: False> needs to be
set
[2021-09-13 11:06:30,124] {process_utils.py:100} INFO - Sending
Signals.SIGTERM to GPID 4174
[2021-09-13 11:06:30,257] {process_utils.py:66} INFO - Process
psutil.Process(pid=4174, status='terminated', exitcode=0, started='11:01:25')
(4174) terminated with exit code 0
[2021-09-13 11:06:30,257] {scheduler_job.py:595} INFO - Exited execute loop
Traceback (most recent call last):
File "/usr/local/bin/airflow", line 33, in <module>
sys.exit(load_entry_point('apache-airflow', 'console_scripts',
'airflow')())
File "/opt/airflow/airflow/__main__.py", line 40, in main
args.func(args)
File "/opt/airflow/airflow/cli/cli_parser.py", line 48, in command
return func(*args, **kwargs)
File "/opt/airflow/airflow/utils/cli.py", line 92, in wrapper
return f(*args, **kwargs)
File "/opt/airflow/airflow/cli/commands/scheduler_command.py", line 70, in
scheduler
job.run()
File "/opt/airflow/airflow/jobs/base_job.py", line 245, in run
self._execute()
File "/opt/airflow/airflow/jobs/scheduler_job.py", line 568, in _execute
self._run_scheduler_loop()
File "/opt/airflow/airflow/jobs/scheduler_job.py", line 649, in
_run_scheduler_loop
num_queued_tis = self._do_scheduling(session)
File "/opt/airflow/airflow/jobs/scheduler_job.py", line 749, in
_do_scheduling
self._send_dag_callbacks_to_processor(dag_run, callback_to_run)
File "/opt/airflow/airflow/jobs/scheduler_job.py", line 1014, in
_send_dag_callbacks_to_processor
dag = dag_run.get_dag()
File "/opt/airflow/airflow/models/dagrun.py", line 395, in get_dag
raise AirflowException(f"The DAG (.dag) for {self} needs to be set")
airflow.exceptions.AirflowException: The DAG (.dag) for <DagRun
employees_etl @ 2021-07-12 16:00:00+00:00:
scheduled__2021-07-12T16:00:00+00:00, externally triggered: False> needs to be
set
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
