2024-04-22T14:35:14.040980966Z .....
2024-04-22T14:35:14.989913941Z /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-04-22T14:35:16.029742860Z /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-04-22T14:35:22.729007693Z [2024-04-22T14:35:22.726+0000] {db.py:755} INFO - Waiting for migrations... 0 second(s)
2024-04-22T14:35:23.733602183Z [2024-04-22T14:35:23.733+0000] {db.py:755} INFO - Waiting for migrations... 1 second(s)
2024-04-22T14:35:24.738875272Z [2024-04-22T14:35:24.738+0000] {db.py:755} INFO - Waiting for migrations... 2 second(s)
2024-04-22T14:35:25.769628699Z [2024-04-22T14:35:25.745+0000] {db.py:755} INFO - Waiting for migrations... 3 second(s)
2024-04-22T14:35:52.291971699Z 
2024-04-22T14:35:53.913103277Z /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-04-22T14:35:55.281941560Z /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-04-22T14:36:09.213471518Z   ____________       _____________
2024-04-22T14:36:09.213497661Z  ____    |__( )_________  __/__  /________      __
2024-04-22T14:36:09.213501380Z ____  /| |_  /__  ___/_  /_ __  /_  __ \_ | /| / /
2024-04-22T14:36:09.213504542Z ___  ___ |  / _  /   _  __/ _  / / /_/ /_ |/ |/ /
2024-04-22T14:36:09.213507518Z  _/_/  |_/_/  /_/    /_/    /_/  \____/____/|__/
2024-04-22T14:36:09.213511277Z [2024-04-22T14:36:09.190+0000] {scheduler_job.py:714} INFO - Starting the scheduler
2024-04-22T14:36:09.213515279Z [2024-04-22T14:36:09.198+0000] {scheduler_job.py:719} INFO - Processing each file at most -1 times
2024-04-22T14:36:10.157011325Z [2024-04-22T14:36:10.156+0000] {executor_loader.py:107} INFO - Loaded executor: CeleryExecutor
2024-04-22T14:36:10.301640569Z [2024-04-22T14:36:10.254+0000] {settings.py:59} INFO - Configured default timezone Timezone('UTC')
2024-04-22T14:36:10.301653909Z [2024-04-22T14:36:10.299+0000] {settings.py:549} INFO - Loaded airflow_local_settings from /opt/airflow/config/airflow_local_settings.py .
2024-04-22T14:36:10.344179368Z [2024-04-22T14:36:10.236+0000] {manager.py:165} INFO - Launched DagFileProcessorManager with pid: 25
2024-04-22T14:36:10.375069986Z [2024-04-22T14:36:10.370+0000] {scheduler_job.py:1410} INFO - Resetting orphaned tasks for active dag runs
2024-04-22T14:36:34.033255962Z [2024-04-22T14:36:34.032+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-04-22T14:36:34.200969206Z [2024-04-22T14:36:34.199+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-04-22T14:36:34.200980405Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:34:00+00:00 [scheduled]>
2024-04-22T14:36:34.200984341Z [2024-04-22T14:36:34.200+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-04-22T14:36:34.202801651Z [2024-04-22T14:36:34.200+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-04-22T14:36:34.202817062Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:34:00+00:00 [scheduled]>
2024-04-22T14:36:34.223786358Z [2024-04-22T14:36:34.222+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-04-22T14:34:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-04-22T14:36:34.224546419Z [2024-04-22T14:36:34.222+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-04-22T14:34:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-04-22T14:36:34.671499813Z [2024-04-22T14:36:34.671+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:34:00+00:00 exited with status queued for try_number 1
2024-04-22T14:36:34.685949897Z [2024-04-22T14:36:34.685+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:34:00+00:00 [queued]> to 37c3d09e-f156-43d5-b83e-0af758eafd7a
2024-04-22T14:36:41.282415254Z [2024-04-22T14:36:41.278+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:34:00+00:00 exited with status success for try_number 1
2024-04-22T14:36:41.316976172Z [2024-04-22T14:36:41.316+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-04-22T14:34:00+00:00, map_index=-1, run_start_date=2024-04-22 14:36:38.120535+00:00, run_end_date=2024-04-22 14:36:40.083493+00:00, run_duration=1.962958, 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-04-22 14:36:34.210045+00:00, queued_by_job_id=2, pid=47
2024-04-22T14:36:50.614886886Z [2024-04-22T14:36:50.614+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-04-22T14:36:50.614909652Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:34:00+00:00 [scheduled]>
2024-04-22T14:36:50.633325459Z [2024-04-22T14:36:50.614+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-04-22T14:36:50.633330233Z [2024-04-22T14:36:50.620+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-04-22T14:36:50.633334230Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:34:00+00:00 [scheduled]>
2024-04-22T14:36:50.633338707Z [2024-04-22T14:36:50.622+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-04-22T14:34:00+00:00', try_number=2, map_index=-1) to executor with priority 1 and queue default
2024-04-22T14:36:50.633364117Z [2024-04-22T14:36:50.622+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-04-22T14:34:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-04-22T14:36:50.893212599Z [2024-04-22T14:36:50.892+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:34:00+00:00 exited with status queued for try_number 2
2024-04-22T14:36:50.920647005Z [2024-04-22T14:36:50.917+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:34:00+00:00 [queued]> to 71312cd6-8038-4724-a673-5c3e81011106
2024-04-22T14:36:56.764104121Z [2024-04-22T14:36:56.708+0000] {dagrun.py:586} ERROR - Marking run <DagRun ns_topology @ 2024-04-22 14:34:00+00:00: scheduled__2024-04-22T14:34:00+00:00, state:running, queued_at: 2024-04-22 14:36:33.965271+00:00. externally triggered: False> failed
2024-04-22T14:36:56.764220772Z [2024-04-22T14:36:56.762+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-04-22 14:34:00+00:00, run_id=scheduled__2024-04-22T14:34:00+00:00, run_start_date=2024-04-22 14:36:34.045330+00:00, run_end_date=2024-04-22 14:36:56.761955+00:00, run_duration=22.716625, state=failed, external_trigger=False, run_type=scheduled, data_interval_start=2024-04-22 14:34:00+00:00, data_interval_end=2024-04-22 14:36:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-04-22T14:36:57.243014125Z [2024-04-22T14:36:57.242+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-04-22T14:36:00+00:00, run_after=2024-04-22T14:38:00+00:00
2024-04-22T14:36:57.620678575Z [2024-04-22T14:36:57.620+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:34:00+00:00 exited with status success for try_number 2
2024-04-22T14:36:57.718163279Z [2024-04-22T14:36:57.711+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-04-22T14:34:00+00:00, map_index=-1, run_start_date=2024-04-22 14:36:53.536475+00:00, run_end_date=2024-04-22 14:36:55.332749+00:00, run_duration=1.796274, 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-04-22 14:36:50.620651+00:00, queued_by_job_id=2, pid=61
2024-04-22T14:38:00.331863060Z [2024-04-22T14:38:00.331+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-04-22T14:38:00.414165928Z [2024-04-22T14:38:00.413+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-04-22T14:38:00.414180069Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:36:00+00:00 [scheduled]>
2024-04-22T14:38:00.414235527Z [2024-04-22T14:38:00.414+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-04-22T14:38:00.414735902Z [2024-04-22T14:38:00.414+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-04-22T14:38:00.414741032Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:36:00+00:00 [scheduled]>
2024-04-22T14:38:00.420997712Z [2024-04-22T14:38:00.416+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-04-22T14:36:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-04-22T14:38:00.421015410Z [2024-04-22T14:38:00.417+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-04-22T14:36:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-04-22T14:38:00.467788616Z [2024-04-22T14:38:00.467+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:36:00+00:00 exited with status queued for try_number 1
2024-04-22T14:38:00.474067054Z [2024-04-22T14:38:00.473+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:36:00+00:00 [queued]> to da9558a3-56eb-4031-92d8-55e7de962c6d
2024-04-22T14:38:02.579748523Z [2024-04-22T14:38:02.579+0000] {dagrun.py:607} INFO - Marking run <DagRun ns_topology @ 2024-04-22 14:36:00+00:00: scheduled__2024-04-22T14:36:00+00:00, state:running, queued_at: 2024-04-22 14:38:00.324360+00:00. externally triggered: False> successful
2024-04-22T14:38:02.580107314Z [2024-04-22T14:38:02.579+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-04-22 14:36:00+00:00, run_id=scheduled__2024-04-22T14:36:00+00:00, run_start_date=2024-04-22 14:38:00.376712+00:00, run_end_date=2024-04-22 14:38:02.579761+00:00, run_duration=2.203049, state=success, external_trigger=False, run_type=scheduled, data_interval_start=2024-04-22 14:36:00+00:00, data_interval_end=2024-04-22 14:38:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-04-22T14:38:02.600486882Z [2024-04-22T14:38:02.600+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-04-22T14:38:00+00:00, run_after=2024-04-22T14:40:00+00:00
2024-04-22T14:38:02.682223194Z [2024-04-22T14:38:02.681+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:36:00+00:00 exited with status success for try_number 1
2024-04-22T14:38:02.696118108Z [2024-04-22T14:38:02.695+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-04-22T14:36:00+00:00, map_index=-1, run_start_date=2024-04-22 14:38:01.592479+00:00, run_end_date=2024-04-22 14:38:02.183707+00:00, run_duration=0.591228, 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-04-22 14:38:00.415137+00:00, queued_by_job_id=2, pid=84
2024-04-22T14:40:00.416299809Z [2024-04-22T14:40:00.415+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-04-22T14:40:00.463398219Z [2024-04-22T14:40:00.462+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-04-22T14:40:00.463414125Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:38:00+00:00 [scheduled]>
2024-04-22T14:40:00.463419000Z [2024-04-22T14:40:00.463+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-04-22T14:40:00.466008652Z [2024-04-22T14:40:00.464+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-04-22T14:40:00.466027661Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:38:00+00:00 [scheduled]>
2024-04-22T14:40:00.467162570Z [2024-04-22T14:40:00.466+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-04-22T14:38:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-04-22T14:40:00.467177519Z [2024-04-22T14:40:00.466+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-04-22T14:38:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-04-22T14:40:00.519635388Z [2024-04-22T14:40:00.519+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:38:00+00:00 exited with status queued for try_number 1
2024-04-22T14:40:00.525397782Z [2024-04-22T14:40:00.525+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:38:00+00:00 [queued]> to cae308e9-e748-47d7-a857-98659b792c80
2024-04-22T14:40:02.778791317Z [2024-04-22T14:40:02.778+0000] {dagrun.py:607} INFO - Marking run <DagRun ns_topology @ 2024-04-22 14:38:00+00:00: scheduled__2024-04-22T14:38:00+00:00, state:running, queued_at: 2024-04-22 14:40:00.405274+00:00. externally triggered: False> successful
2024-04-22T14:40:02.779149830Z [2024-04-22T14:40:02.778+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-04-22 14:38:00+00:00, run_id=scheduled__2024-04-22T14:38:00+00:00, run_start_date=2024-04-22 14:40:00.427497+00:00, run_end_date=2024-04-22 14:40:02.778739+00:00, run_duration=2.351242, state=success, external_trigger=False, run_type=scheduled, data_interval_start=2024-04-22 14:38:00+00:00, data_interval_end=2024-04-22 14:40:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-04-22T14:40:02.790815916Z [2024-04-22T14:40:02.790+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-04-22T14:40:00+00:00, run_after=2024-04-22T14:42:00+00:00
2024-04-22T14:40:02.829119068Z [2024-04-22T14:40:02.828+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:38:00+00:00 exited with status success for try_number 1
2024-04-22T14:40:02.835926401Z [2024-04-22T14:40:02.835+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-04-22T14:38:00+00:00, map_index=-1, run_start_date=2024-04-22 14:40:01.346093+00:00, run_end_date=2024-04-22 14:40:01.849637+00:00, run_duration=0.503544, 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-04-22 14:40:00.464586+00:00, queued_by_job_id=2, pid=121
2024-04-22T14:41:10.865422566Z [2024-04-22T14:41:10.853+0000] {scheduler_job.py:1410} INFO - Resetting orphaned tasks for active dag runs
2024-04-22T14:42:00.056998034Z [2024-04-22T14:42:00.056+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-04-22T14:42:00.101129399Z [2024-04-22T14:42:00.100+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-04-22T14:42:00.101143760Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:40:00+00:00 [scheduled]>
2024-04-22T14:42:00.101522776Z [2024-04-22T14:42:00.101+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-04-22T14:42:00.101804901Z [2024-04-22T14:42:00.101+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-04-22T14:42:00.101810657Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:40:00+00:00 [scheduled]>
2024-04-22T14:42:00.107862470Z [2024-04-22T14:42:00.107+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-04-22T14:40:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-04-22T14:42:00.107911139Z [2024-04-22T14:42:00.107+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-04-22T14:40:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-04-22T14:42:00.183744039Z [2024-04-22T14:42:00.176+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:40:00+00:00 exited with status queued for try_number 1
2024-04-22T14:42:00.188542645Z [2024-04-22T14:42:00.188+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:40:00+00:00 [queued]> to e0136ec6-cc13-48b9-92db-9c8fbd9941eb
2024-04-22T14:42:02.294429779Z [2024-04-22T14:42:02.293+0000] {dagrun.py:607} INFO - Marking run <DagRun ns_topology @ 2024-04-22 14:40:00+00:00: scheduled__2024-04-22T14:40:00+00:00, state:running, queued_at: 2024-04-22 14:42:00.050697+00:00. externally triggered: False> successful
2024-04-22T14:42:02.295623004Z [2024-04-22T14:42:02.294+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-04-22 14:40:00+00:00, run_id=scheduled__2024-04-22T14:40:00+00:00, run_start_date=2024-04-22 14:42:00.069095+00:00, run_end_date=2024-04-22 14:42:02.294569+00:00, run_duration=2.225474, state=success, external_trigger=False, run_type=scheduled, data_interval_start=2024-04-22 14:40:00+00:00, data_interval_end=2024-04-22 14:42:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-04-22T14:42:02.309154000Z [2024-04-22T14:42:02.308+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-04-22T14:42:00+00:00, run_after=2024-04-22T14:44:00+00:00
2024-04-22T14:42:02.353941720Z [2024-04-22T14:42:02.353+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:40:00+00:00 exited with status success for try_number 1
2024-04-22T14:42:02.361928611Z [2024-04-22T14:42:02.360+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-04-22T14:40:00+00:00, map_index=-1, run_start_date=2024-04-22 14:42:01.289467+00:00, run_end_date=2024-04-22 14:42:01.753453+00:00, run_duration=0.463986, 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-04-22 14:42:00.105732+00:00, queued_by_job_id=2, pid=157
2024-04-22T14:44:00.428667702Z [2024-04-22T14:44:00.428+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-04-22T14:44:00.475190055Z [2024-04-22T14:44:00.474+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-04-22T14:44:00.475239929Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:42:00+00:00 [scheduled]>
2024-04-22T14:44:00.475365262Z [2024-04-22T14:44:00.475+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-04-22T14:44:00.476055047Z [2024-04-22T14:44:00.475+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-04-22T14:44:00.476061021Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:42:00+00:00 [scheduled]>
2024-04-22T14:44:00.478822051Z [2024-04-22T14:44:00.478+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-04-22T14:42:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-04-22T14:44:00.479016463Z [2024-04-22T14:44:00.478+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-04-22T14:42:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-04-22T14:44:00.526717983Z [2024-04-22T14:44:00.526+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:42:00+00:00 exited with status queued for try_number 1
2024-04-22T14:44:00.535909974Z [2024-04-22T14:44:00.535+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:42:00+00:00 [queued]> to 742a1342-5e95-4fb2-8a36-84e86f671709
2024-04-22T14:44:02.801195897Z [2024-04-22T14:44:02.796+0000] {dagrun.py:607} INFO - Marking run <DagRun ns_topology @ 2024-04-22 14:42:00+00:00: scheduled__2024-04-22T14:42:00+00:00, state:running, queued_at: 2024-04-22 14:44:00.422662+00:00. externally triggered: False> successful
2024-04-22T14:44:02.801213237Z [2024-04-22T14:44:02.799+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-04-22 14:42:00+00:00, run_id=scheduled__2024-04-22T14:42:00+00:00, run_start_date=2024-04-22 14:44:00.439959+00:00, run_end_date=2024-04-22 14:44:02.799339+00:00, run_duration=2.35938, state=success, external_trigger=False, run_type=scheduled, data_interval_start=2024-04-22 14:42:00+00:00, data_interval_end=2024-04-22 14:44:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-04-22T14:44:02.827427812Z [2024-04-22T14:44:02.824+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-04-22T14:44:00+00:00, run_after=2024-04-22T14:46:00+00:00
2024-04-22T14:44:02.877713621Z [2024-04-22T14:44:02.877+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:42:00+00:00 exited with status success for try_number 1
2024-04-22T14:44:02.883310137Z [2024-04-22T14:44:02.882+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-04-22T14:42:00+00:00, map_index=-1, run_start_date=2024-04-22 14:44:01.349160+00:00, run_end_date=2024-04-22 14:44:01.764980+00:00, run_duration=0.41582, 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-04-22 14:44:00.476560+00:00, queued_by_job_id=2, pid=196
2024-04-22T14:46:00.951353839Z [2024-04-22T14:46:00.945+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-04-22T14:46:01.022205564Z [2024-04-22T14:46:01.021+0000] {scheduler_job.py:360} INFO - 1 tasks up for execution:
2024-04-22T14:46:01.022220613Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:44:00+00:00 [scheduled]>
2024-04-22T14:46:01.023261626Z [2024-04-22T14:46:01.022+0000] {scheduler_job.py:425} INFO - DAG ns_topology has 0/16 running and queued tasks
2024-04-22T14:46:01.024153439Z [2024-04-22T14:46:01.023+0000] {scheduler_job.py:511} INFO - Setting the following tasks to queued state:
2024-04-22T14:46:01.024177954Z 	<TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:44:00+00:00 [scheduled]>
2024-04-22T14:46:01.028067870Z [2024-04-22T14:46:01.027+0000] {scheduler_job.py:550} INFO - Sending TaskInstanceKey(dag_id='ns_topology', task_id='get_topology', run_id='scheduled__2024-04-22T14:44:00+00:00', try_number=1, map_index=-1) to executor with priority 1 and queue default
2024-04-22T14:46:01.029374432Z [2024-04-22T14:46:01.028+0000] {base_executor.py:93} INFO - Adding to queue: ['airflow', 'tasks', 'run', 'ns_topology', 'get_topology', 'scheduled__2024-04-22T14:44:00+00:00', '--local', '--subdir', 'DAGS_FOLDER/dags/ns_topology.py']
2024-04-22T14:46:01.118061086Z [2024-04-22T14:46:01.117+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:44:00+00:00 exited with status queued for try_number 1
2024-04-22T14:46:01.129966851Z [2024-04-22T14:46:01.129+0000] {scheduler_job.py:635} INFO - Setting external_id for <TaskInstance: ns_topology.get_topology scheduled__2024-04-22T14:44:00+00:00 [queued]> to 2a8e57c9-e934-4cb8-81e8-cbe4e791a568
2024-04-22T14:46:02.335692315Z [2024-04-22T14:46:02.335+0000] {dagrun.py:607} INFO - Marking run <DagRun ns_topology @ 2024-04-22 14:44:00+00:00: scheduled__2024-04-22T14:44:00+00:00, state:running, queued_at: 2024-04-22 14:46:00.934084+00:00. externally triggered: False> successful
2024-04-22T14:46:02.336053039Z [2024-04-22T14:46:02.335+0000] {dagrun.py:658} INFO - DagRun Finished: dag_id=ns_topology, execution_date=2024-04-22 14:44:00+00:00, run_id=scheduled__2024-04-22T14:44:00+00:00, run_start_date=2024-04-22 14:46:00.970832+00:00, run_end_date=2024-04-22 14:46:02.335742+00:00, run_duration=1.36491, state=success, external_trigger=False, run_type=scheduled, data_interval_start=2024-04-22 14:44:00+00:00, data_interval_end=2024-04-22 14:46:00+00:00, dag_hash=e360c04dc0c257e4994be7d04f1a0de1
2024-04-22T14:46:02.371868050Z [2024-04-22T14:46:02.371+0000] {dag.py:3452} INFO - Setting next_dagrun for ns_topology to 2024-04-22T14:46:00+00:00, run_after=2024-04-22T14:48:00+00:00
2024-04-22T14:46:03.494889261Z [2024-04-22T14:46:03.494+0000] {scheduler_job.py:602} INFO - Executor reports execution of ns_topology.get_topology run_id=scheduled__2024-04-22T14:44:00+00:00 exited with status success for try_number 1
2024-04-22T14:46:03.503984783Z [2024-04-22T14:46:03.503+0000] {scheduler_job.py:645} INFO - TaskInstance Finished: dag_id=ns_topology, task_id=get_topology, run_id=scheduled__2024-04-22T14:44:00+00:00, map_index=-1, run_start_date=2024-04-22 14:46:01.903429+00:00, run_end_date=2024-04-22 14:46:02.299422+00:00, run_duration=0.395993, 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-04-22 14:46:01.024607+00:00, queued_by_job_id=2, pid=233
2024-04-22T14:46:10.951616246Z [2024-04-22T14:46:10.947+0000] {scheduler_job.py:1410} INFO - Resetting orphaned tasks for active dag runs
2024-04-22T14:35:51.145486777Z 
2024-04-22T14:35:51.153289160Z Cleaning logs every 900 seconds
2024-04-22T14:35:51.153306840Z Trimming airflow logs to 15 days.
2024-04-22T14:45:00.274849786Z Trimming airflow logs to 15 days.
2024-04-22T14:45:01.311741125Z Trimming airflow logs to 15 days.