2024-06-15T09:55:37.685853694Z .....
2024-06-15T09:55:38.674495778Z /home/airflow/.local/lib/python3.10/site-packages/airflow/configuration.py:384 FutureWarning: The auth_backends setting in [api] has had airflow.api.auth.backend.session added in the running config, which is needed by the UI. Please update your config before Apache Airflow 3.0.
2024-06-15T09:55:39.496808371Z /home/airflow/.local/lib/python3.10/site-packages/airflow/models/base.py:49 MovedIn20Warning: Deprecated API features detected! These feature(s) are not compatible with SQLAlchemy 2.0. To prevent incompatible upgrades prior to updating applications, ensure requirements files are pinned to "sqlalchemy<2.0". Set environment variable SQLALCHEMY_WARN_20=1 to show all deprecation warnings.  Set environment variable SQLALCHEMY_SILENCE_UBER_WARNING=1 to silence this message. (Background on SQLAlchemy 2.0 at: https://sqlalche.me/e/b8d9)
2024-06-15T09:55:44.032118286Z [2024-06-15T09:55:44.025+0000] {db.py:755} INFO - Waiting for migrations... 0 second(s)
2024-06-15T09:55:45.041880132Z [2024-06-15T09:55:45.038+0000] {db.py:755} INFO - Waiting for migrations... 1 second(s)
2024-06-15T09:55:46.046942180Z [2024-06-15T09:55:46.046+0000] {db.py:755} INFO - Waiting for migrations... 2 second(s)
2024-06-15T09:55:47.052906863Z [2024-06-15T09:55:47.048+0000] {db.py:755} INFO - Waiting for migrations... 3 second(s)
2024-06-15T09:55:48.070175122Z [2024-06-15T09:55:48.069+0000] {db.py:755} INFO - Waiting for migrations... 4 second(s)
2024-06-15T09:56:09.179845112Z 
2024-06-15T09:56:09.854343386Z /home/airflow/.local/lib/python3.10/site-packages/airflow/configuration.py:384 FutureWarning: The auth_backends setting in [api] has had airflow.api.auth.backend.session added in the running config, which is needed by the UI. Please update your config before Apache Airflow 3.0.
2024-06-15T09:56:12.396156209Z /home/airflow/.local/lib/python3.10/site-packages/airflow/models/base.py:49 MovedIn20Warning: Deprecated API features detected! These feature(s) are not compatible with SQLAlchemy 2.0. To prevent incompatible upgrades prior to updating applications, ensure requirements files are pinned to "sqlalchemy<2.0". Set environment variable SQLALCHEMY_WARN_20=1 to show all deprecation warnings.  Set environment variable SQLALCHEMY_SILENCE_UBER_WARNING=1 to silence this message. (Background on SQLAlchemy 2.0 at: https://sqlalche.me/e/b8d9)
2024-06-15T09:56:24.016834999Z   ____________       _____________
2024-06-15T09:56:24.016853690Z  ____    |__( )_________  __/__  /________      __
2024-06-15T09:56:24.016857167Z ____  /| |_  /__  ___/_  /_ __  /_  __ \_ | /| / /
2024-06-15T09:56:24.016860304Z ___  ___ |  / _  /   _  __/ _  / / /_/ /_ |/ |/ /
2024-06-15T09:56:24.016863354Z  _/_/  |_/_/  /_/    /_/    /_/  \____/____/|__/
2024-06-15T09:56:24.016867081Z [2024-06-15T09:56:24.010+0000] {scheduler_job.py:714} INFO - Starting the scheduler
2024-06-15T09:56:24.016870944Z [2024-06-15T09:56:24.011+0000] {scheduler_job.py:719} INFO - Processing each file at most -1 times
2024-06-15T09:56:24.448313546Z [2024-06-15T09:56:24.447+0000] {executor_loader.py:107} INFO - Loaded executor: CeleryExecutor
2024-06-15T09:56:24.473688197Z [2024-06-15T09:56:24.456+0000] {manager.py:165} INFO - Launched DagFileProcessorManager with pid: 17
2024-06-15T09:56:24.477665231Z [2024-06-15T09:56:24.475+0000] {scheduler_job.py:1410} INFO - Resetting orphaned tasks for active dag runs
2024-06-15T09:56:24.499407748Z [2024-06-15T09:56:24.493+0000] {settings.py:59} INFO - Configured default timezone Timezone('UTC')
2024-06-15T09:56:24.502765455Z [2024-06-15T09:56:24.502+0000] {settings.py:549} INFO - Loaded airflow_local_settings from /opt/airflow/config/airflow_local_settings.py .
2024-06-15T09:56:40.175902732Z [2024-06-15T09:56:40.174+0000] {scheduler_job.py:1197} INFO - DAG ns_topology is at (or above) max_active_runs (1 of 1), not creating any more runs
2024-06-15T09:56:40.290096946Z [2024-06-15T09:56:40.289+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-06-15T09:56:40.290115447Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:54:00+00:00 [scheduled]>
2024-06-15T09:56:40.290899705Z [2024-06-15T09:56:40.290+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-06-15T09:56:40.291566917Z [2024-06-15T09:56:40.291+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-06-15T09:56:40.291574793Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:54:00+00:00 [scheduled]>
2024-06-15T09:56:40.294927497Z [2024-06-15T09:56:40.294+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-06-15T09:54:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-06-15T09:56:40.295939308Z [2024-06-15T09:56:40.295+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-06-15T09:54:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-06-15T09:56:40.901493935Z [2024-06-15T09:56:40.898+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T09:54:00+00:00 exited with status queued for try_number 1
2024-06-15T09:56:40.955506891Z [2024-06-15T09:56:40.954+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:54:00+00:00 [queued]> to 6e15012e-4f60-4ac1-b445-331cf69b1b81
2024-06-15T09:56:43.806386960Z [2024-06-15T09:56:43.803+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T09:54:00+00:00 exited with status success for try_number 1
2024-06-15T09:56:43.831769665Z [2024-06-15T09:56:43.831+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-06-15T09:54:00+00:00, map_index=-1, run_start_date=2024-06-15 09:56:41.849115+00:00, run_end_date=2024-06-15 09:56:43.064785+00:00, run_duration=1.21567, state=up_for_retry, executor_state=success, try_number=1, max_tries=1, job_id=3, pool=default_pool, queue=default, priority_weight=1, operator=_PythonDecoratedOperator, queued_dttm=2024-06-15 09:56:40.292106+00:00, queued_by_job_id=1, pid=49
2024-06-15T09:56:53.622415822Z [2024-06-15T09:56:53.621+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-06-15T09:56:53.622440219Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:54:00+00:00 [scheduled]>
2024-06-15T09:56:53.622445578Z [2024-06-15T09:56:53.622+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-06-15T09:56:53.622834687Z [2024-06-15T09:56:53.622+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-06-15T09:56:53.622848427Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:54:00+00:00 [scheduled]>
2024-06-15T09:56:53.625697579Z [2024-06-15T09:56:53.624+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-06-15T09:54:00+00:00', try_number=2, map_index=-1) to executor with priority 1 and queue default
2024-06-15T09:56:53.625716292Z [2024-06-15T09:56:53.624+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-06-15T09:54:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-06-15T09:56:53.696217823Z [2024-06-15T09:56:53.695+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T09:54:00+00:00 exited with status queued for try_number 2
2024-06-15T09:56:53.702090086Z [2024-06-15T09:56:53.701+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:54:00+00:00 [queued]> to 41cf8ebe-6894-4df3-8936-960d4df73943
2024-06-15T09:56:56.093392152Z [2024-06-15T09:56:56.091+0000] {dagrun.py:586} ERROR - Marking run <DagRun ns_topology @ 2024-06-15 09:54:00+00:00: scheduled__2024-06-15T09:54:00+00:00, state:running, queued_at: 2024-06-15 09:56:40.065624+00:00. externally triggered: False> failed
2024-06-15T09:56:56.099621849Z [2024-06-15T09:56:56.093+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-06-15 09:54:00+00:00, run_id=scheduled__2024-06-15T09:54:00+00:00, run_start_date=2024-06-15 09:56:40.202173+00:00, run_end_date=2024-06-15 09:56:56.092860+00:00, run_duration=15.890687, state=failed, external_trigger=False, run_type=scheduled, data_interval_start=2024-06-15 09:54:00+00:00, data_interval_end=2024-06-15 09:56:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-06-15T09:56:56.154286382Z [2024-06-15T09:56:56.153+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-06-15T09:56:00+00:00, run_after=2024-06-15T09:58:00+00:00
2024-06-15T09:56:56.488939561Z [2024-06-15T09:56:56.488+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T09:54:00+00:00 exited with status success for try_number 2
2024-06-15T09:56:56.507177838Z [2024-06-15T09:56:56.505+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-06-15T09:54:00+00:00, map_index=-1, run_start_date=2024-06-15 09:56:55.029876+00:00, run_end_date=2024-06-15 09:56:55.952775+00:00, run_duration=0.922899, state=failed, executor_state=success, try_number=2, max_tries=1, job_id=4, pool=default_pool, queue=default, priority_weight=1, operator=_PythonDecoratedOperator, queued_dttm=2024-06-15 09:56:53.623095+00:00, queued_by_job_id=1, pid=60
2024-06-15T09:58:00.845362877Z [2024-06-15T09:58:00.844+0000] {scheduler_job.py:1197} INFO - DAG ns_topology is at (or above) max_active_runs (1 of 1), not creating any more runs
2024-06-15T09:58:00.911346539Z [2024-06-15T09:58:00.910+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-06-15T09:58:00.911665408Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:56:00+00:00 [scheduled]>
2024-06-15T09:58:00.911687337Z [2024-06-15T09:58:00.911+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-06-15T09:58:00.912269146Z [2024-06-15T09:58:00.911+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-06-15T09:58:00.912282091Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:56:00+00:00 [scheduled]>
2024-06-15T09:58:00.915396741Z [2024-06-15T09:58:00.915+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-06-15T09:56:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-06-15T09:58:00.915564571Z [2024-06-15T09:58:00.915+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-06-15T09:56:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-06-15T09:58:01.074446856Z [2024-06-15T09:58:01.074+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T09:56:00+00:00 exited with status queued for try_number 1
2024-06-15T09:58:01.083908018Z [2024-06-15T09:58:01.083+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:56:00+00:00 [queued]> to 4a50d132-ae71-4954-9a27-ce85fbae3825
2024-06-15T09:58:03.549060323Z [2024-06-15T09:58:03.548+0000] {dagrun.py:607} INFO - Marking run <DagRun ns_topology @ 2024-06-15 09:56:00+00:00: scheduled__2024-06-15T09:56:00+00:00, state:running, queued_at: 2024-06-15 09:58:00.833232+00:00. externally triggered: False> successful
2024-06-15T09:58:03.549254455Z [2024-06-15T09:58:03.549+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-06-15 09:56:00+00:00, run_id=scheduled__2024-06-15T09:56:00+00:00, run_start_date=2024-06-15 09:58:00.861065+00:00, run_end_date=2024-06-15 09:58:03.548995+00:00, run_duration=2.68793, state=success, external_trigger=False, run_type=scheduled, data_interval_start=2024-06-15 09:56:00+00:00, data_interval_end=2024-06-15 09:58:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-06-15T09:58:03.556103917Z [2024-06-15T09:58:03.555+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-06-15T09:58:00+00:00, run_after=2024-06-15T10:00:00+00:00
2024-06-15T09:58:03.602971148Z [2024-06-15T09:58:03.602+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T09:56:00+00:00 exited with status success for try_number 1
2024-06-15T09:58:03.610160533Z [2024-06-15T09:58:03.609+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-06-15T09:56:00+00:00, map_index=-1, run_start_date=2024-06-15 09:58:02.076790+00:00, run_end_date=2024-06-15 09:58:02.778264+00:00, run_duration=0.701474, state=success, executor_state=success, try_number=1, max_tries=1, job_id=5, pool=default_pool, queue=default, priority_weight=1, operator=_PythonDecoratedOperator, queued_dttm=2024-06-15 09:58:00.912692+00:00, queued_by_job_id=1, pid=94
2024-06-15T10:00:00.849403331Z [2024-06-15T10:00:00.848+0000] {scheduler_job.py:1197} INFO - DAG ns_topology is at (or above) max_active_runs (1 of 1), not creating any more runs
2024-06-15T10:00:00.896925214Z [2024-06-15T10:00:00.896+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-06-15T10:00:00.896940220Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:58:00+00:00 [scheduled]>
2024-06-15T10:00:00.896958393Z [2024-06-15T10:00:00.896+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-06-15T10:00:00.897733669Z [2024-06-15T10:00:00.897+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-06-15T10:00:00.897744284Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:58:00+00:00 [scheduled]>
2024-06-15T10:00:00.900238206Z [2024-06-15T10:00:00.900+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-06-15T09:58:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-06-15T10:00:00.900308216Z [2024-06-15T10:00:00.900+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-06-15T09:58:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-06-15T10:00:00.967943767Z [2024-06-15T10:00:00.967+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T09:58:00+00:00 exited with status queued for try_number 1
2024-06-15T10:00:00.974550179Z [2024-06-15T10:00:00.974+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-06-15T09:58:00+00:00 [queued]> to 6ce3700d-03de-4b14-8dc4-8ba787cdb910
2024-06-15T10:00:02.704858989Z [2024-06-15T10:00:02.704+0000] {dagrun.py:607} INFO - Marking run <DagRun ns_topology @ 2024-06-15 09:58:00+00:00: scheduled__2024-06-15T09:58:00+00:00, state:running, queued_at: 2024-06-15 10:00:00.836970+00:00. externally triggered: False> successful
2024-06-15T10:00:02.705253764Z [2024-06-15T10:00:02.705+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-06-15 09:58:00+00:00, run_id=scheduled__2024-06-15T09:58:00+00:00, run_start_date=2024-06-15 10:00:00.860623+00:00, run_end_date=2024-06-15 10:00:02.704886+00:00, run_duration=1.844263, state=success, external_trigger=False, run_type=scheduled, data_interval_start=2024-06-15 09:58:00+00:00, data_interval_end=2024-06-15 10:00:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-06-15T10:00:02.712885891Z [2024-06-15T10:00:02.712+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-06-15T10:00:00+00:00, run_after=2024-06-15T10:02:00+00:00
2024-06-15T10:00:02.749917653Z [2024-06-15T10:00:02.749+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T09:58:00+00:00 exited with status success for try_number 1
2024-06-15T10:00:02.757197113Z [2024-06-15T10:00:02.756+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-06-15T09:58:00+00:00, map_index=-1, run_start_date=2024-06-15 10:00:01.872556+00:00, run_end_date=2024-06-15 10:00:02.513886+00:00, run_duration=0.64133, state=success, executor_state=success, try_number=1, max_tries=1, job_id=6, pool=default_pool, queue=default, priority_weight=1, operator=_PythonDecoratedOperator, queued_dttm=2024-06-15 10:00:00.898021+00:00, queued_by_job_id=1, pid=132
2024-06-15T10:01:24.948455276Z [2024-06-15T10:01:24.947+0000] {scheduler_job.py:1410} INFO - Resetting orphaned tasks for active dag runs
2024-06-15T10:02:00.434758250Z [2024-06-15T10:02:00.434+0000] {scheduler_job.py:1197} INFO - DAG ns_topology is at (or above) max_active_runs (1 of 1), not creating any more runs
2024-06-15T10:02:00.486844672Z [2024-06-15T10:02:00.486+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-06-15T10:02:00.486859081Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T10:00:00+00:00 [scheduled]>
2024-06-15T10:02:00.487277368Z [2024-06-15T10:02:00.487+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-06-15T10:02:00.488122077Z [2024-06-15T10:02:00.487+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-06-15T10:02:00.488131765Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T10:00:00+00:00 [scheduled]>
2024-06-15T10:02:00.491500388Z [2024-06-15T10:02:00.491+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-06-15T10:00:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-06-15T10:02:00.492063453Z [2024-06-15T10:02:00.491+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-06-15T10:00:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-06-15T10:02:00.576582813Z [2024-06-15T10:02:00.576+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T10:00:00+00:00 exited with status queued for try_number 1
2024-06-15T10:02:00.581098592Z [2024-06-15T10:02:00.580+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-06-15T10:00:00+00:00 [queued]> to d80b5200-4a27-4e15-9aa4-6a6225ed6cf9
2024-06-15T10:02:02.849544378Z [2024-06-15T10:02:02.848+0000] {dagrun.py:607} INFO - Marking run <DagRun ns_topology @ 2024-06-15 10:00:00+00:00: scheduled__2024-06-15T10:00:00+00:00, state:running, queued_at: 2024-06-15 10:02:00.425562+00:00. externally triggered: False> successful
2024-06-15T10:02:02.849772092Z [2024-06-15T10:02:02.849+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-06-15 10:00:00+00:00, run_id=scheduled__2024-06-15T10:00:00+00:00, run_start_date=2024-06-15 10:02:00.446449+00:00, run_end_date=2024-06-15 10:02:02.849387+00:00, run_duration=2.402938, state=success, external_trigger=False, run_type=scheduled, data_interval_start=2024-06-15 10:00:00+00:00, data_interval_end=2024-06-15 10:02:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-06-15T10:02:02.858020656Z [2024-06-15T10:02:02.857+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-06-15T10:02:00+00:00, run_after=2024-06-15T10:04:00+00:00
2024-06-15T10:02:02.891329153Z [2024-06-15T10:02:02.891+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T10:00:00+00:00 exited with status success for try_number 1
2024-06-15T10:02:02.896229623Z [2024-06-15T10:02:02.895+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-06-15T10:00:00+00:00, map_index=-1, run_start_date=2024-06-15 10:02:01.417405+00:00, run_end_date=2024-06-15 10:02:01.814827+00:00, run_duration=0.397422, state=success, executor_state=success, try_number=1, max_tries=1, job_id=7, pool=default_pool, queue=default, priority_weight=1, operator=_PythonDecoratedOperator, queued_dttm=2024-06-15 10:02:00.488924+00:00, queued_by_job_id=1, pid=169
2024-06-15T10:04:00.711785031Z [2024-06-15T10:04:00.710+0000] {scheduler_job.py:1197} INFO - DAG ns_topology is at (or above) max_active_runs (1 of 1), not creating any more runs
2024-06-15T10:04:00.768742628Z [2024-06-15T10:04:00.767+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-06-15T10:04:00.768767466Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T10:02:00+00:00 [scheduled]>
2024-06-15T10:04:00.769117714Z [2024-06-15T10:04:00.768+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-06-15T10:04:00.771119520Z [2024-06-15T10:04:00.770+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-06-15T10:04:00.771137159Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T10:02:00+00:00 [scheduled]>
2024-06-15T10:04:00.777254873Z [2024-06-15T10:04:00.776+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-06-15T10:02:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-06-15T10:04:00.777825617Z [2024-06-15T10:04:00.777+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-06-15T10:02:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-06-15T10:04:00.849490160Z [2024-06-15T10:04:00.849+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T10:02:00+00:00 exited with status queued for try_number 1
2024-06-15T10:04:00.854526980Z [2024-06-15T10:04:00.854+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-06-15T10:02:00+00:00 [queued]> to ca625314-7b16-47fc-8a5d-8f086f10db7b
2024-06-15T10:04:03.054261273Z [2024-06-15T10:04:03.053+0000] {dagrun.py:607} INFO - Marking run <DagRun ns_topology @ 2024-06-15 10:02:00+00:00: scheduled__2024-06-15T10:02:00+00:00, state:running, queued_at: 2024-06-15 10:04:00.703461+00:00. externally triggered: False> successful
2024-06-15T10:04:03.054638811Z [2024-06-15T10:04:03.054+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-06-15 10:02:00+00:00, run_id=scheduled__2024-06-15T10:02:00+00:00, run_start_date=2024-06-15 10:04:00.724882+00:00, run_end_date=2024-06-15 10:04:03.054198+00:00, run_duration=2.329316, state=success, external_trigger=False, run_type=scheduled, data_interval_start=2024-06-15 10:02:00+00:00, data_interval_end=2024-06-15 10:04:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-06-15T10:04:03.064738489Z [2024-06-15T10:04:03.064+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-06-15T10:04:00+00:00, run_after=2024-06-15T10:06:00+00:00
2024-06-15T10:04:03.133595056Z [2024-06-15T10:04:03.133+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T10:02:00+00:00 exited with status success for try_number 1
2024-06-15T10:04:03.147380788Z [2024-06-15T10:04:03.146+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-06-15T10:02:00+00:00, map_index=-1, run_start_date=2024-06-15 10:04:01.636277+00:00, run_end_date=2024-06-15 10:04:02.043635+00:00, run_duration=0.407358, state=success, executor_state=success, try_number=1, max_tries=1, job_id=8, pool=default_pool, queue=default, priority_weight=1, operator=_PythonDecoratedOperator, queued_dttm=2024-06-15 10:04:00.771849+00:00, queued_by_job_id=1, pid=205
2024-06-15T10:06:00.777622377Z [2024-06-15T10:06:00.777+0000] {scheduler_job.py:1197} INFO - DAG ns_topology is at (or above) max_active_runs (1 of 1), not creating any more runs
2024-06-15T10:06:00.848814235Z [2024-06-15T10:06:00.848+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-06-15T10:06:00.848824837Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T10:04:00+00:00 [scheduled]>
2024-06-15T10:06:00.848988289Z [2024-06-15T10:06:00.848+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-06-15T10:06:00.852054374Z [2024-06-15T10:06:00.851+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-06-15T10:06:00.852077155Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-06-15T10:04:00+00:00 [scheduled]>
2024-06-15T10:06:00.854850909Z [2024-06-15T10:06:00.854+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-06-15T10:04:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-06-15T10:06:00.855088765Z [2024-06-15T10:06:00.854+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-06-15T10:04:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-06-15T10:06:00.903560657Z [2024-06-15T10:06:00.903+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T10:04:00+00:00 exited with status queued for try_number 1
2024-06-15T10:06:00.912298935Z [2024-06-15T10:06:00.911+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-06-15T10:04:00+00:00 [queued]> to 7926efeb-805f-43dd-9360-87fe88c2a3ff
2024-06-15T10:06:02.498729425Z [2024-06-15T10:06:02.498+0000] {dagrun.py:607} INFO - Marking run <DagRun ns_topology @ 2024-06-15 10:04:00+00:00: scheduled__2024-06-15T10:04:00+00:00, state:running, queued_at: 2024-06-15 10:06:00.771259+00:00. externally triggered: False> successful
2024-06-15T10:06:02.499099443Z [2024-06-15T10:06:02.498+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-06-15 10:04:00+00:00, run_id=scheduled__2024-06-15T10:04:00+00:00, run_start_date=2024-06-15 10:06:00.790394+00:00, run_end_date=2024-06-15 10:06:02.498674+00:00, run_duration=1.70828, state=success, external_trigger=False, run_type=scheduled, data_interval_start=2024-06-15 10:04:00+00:00, data_interval_end=2024-06-15 10:06:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-06-15T10:06:02.507752775Z [2024-06-15T10:06:02.507+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-06-15T10:06:00+00:00, run_after=2024-06-15T10:08:00+00:00
2024-06-15T10:06:02.548666580Z [2024-06-15T10:06:02.548+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-06-15T10:04:00+00:00 exited with status success for try_number 1
2024-06-15T10:06:02.564695443Z [2024-06-15T10:06:02.564+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-06-15T10:04:00+00:00, map_index=-1, run_start_date=2024-06-15 10:06:01.888843+00:00, run_end_date=2024-06-15 10:06:02.260536+00:00, run_duration=0.371693, state=success, executor_state=success, try_number=1, max_tries=1, job_id=9, pool=default_pool, queue=default, priority_weight=1, operator=_PythonDecoratedOperator, queued_dttm=2024-06-15 10:06:00.852363+00:00, queued_by_job_id=1, pid=242
2024-06-15T09:56:05.385525640Z 
2024-06-15T09:56:05.408833245Z Cleaning logs every 900 seconds
2024-06-15T09:56:05.408856591Z Trimming airflow logs to 15 days.
2024-06-15T10:00:00.471086886Z Trimming airflow logs to 15 days.
2024-06-15T10:00:01.493469166Z Trimming airflow logs to 15 days.