Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T06:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T07:11:50.174989+00:00 2023-05-28T07:11:51.223818+00:00 0:00:01.048829 387121 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T07:11:48.100055+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T06:00:00+00:00 PythonOperator 2023-05-28T07:11:28.121151+00:00 2023-05-28T07:11:28.994008+00:00 0:00:00.872857 387118 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T07:11:26.080306+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T05:00:00+00:00 TriggerDagRunOperator 2023-05-28T06:11:33.159635+00:00 2023-05-28T06:11:33.580070+00:00 0:00:00.420435 387107 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T06:11:31.065153+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T05:00:00+00:00 TriggerDagRunOperator 2023-05-28T06:11:33.096203+00:00 2023-05-28T06:11:33.538342+00:00 0:00:00.442139 387106 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T06:11:31.065125+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T05:00:00+00:00 EmrJobFlowSensor 2023-05-28T06:01:07.818970+00:00 2023-05-28T06:11:09.626024+00:00 0:10:01.807054 387100 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T06:01:05.687089+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T05:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T06:00:46.138157+00:00 2023-05-28T06:00:47.031747+00:00 0:00:00.893590 387098 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T06:00:43.671051+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T05:00:00+00:00 PythonOperator 2023-05-28T06:00:25.697050+00:00 2023-05-28T06:00:26.631053+00:00 0:00:00.934003 387096 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T06:00:23.649881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T04:00:00+00:00 TriggerDagRunOperator 2023-05-28T05:11:06.168572+00:00 2023-05-28T05:11:06.596558+00:00 0:00:00.427986 387086 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T05:11:03.607006+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T04:00:00+00:00 TriggerDagRunOperator 2023-05-28T05:11:06.122588+00:00 2023-05-28T05:11:06.578507+00:00 0:00:00.455919 387085 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T05:11:03.606978+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T04:00:00+00:00 EmrJobFlowSensor 2023-05-28T05:01:45.341587+00:00 2023-05-28T05:10:46.936131+00:00 0:09:01.594544 387079 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T05:01:43.292210+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T04:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T05:00:44.114623+00:00 2023-05-28T05:00:45.160913+00:00 0:00:01.046290 387076 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T05:00:41.282784+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T04:00:00+00:00 PythonOperator 2023-05-28T05:00:23.303328+00:00 2023-05-28T05:00:24.208169+00:00 0:00:00.904841 387074 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T05:00:21.262312+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T03:00:00+00:00 TriggerDagRunOperator 2023-05-28T04:11:29.107198+00:00 2023-05-28T04:11:29.523814+00:00 0:00:00.416616 387064 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T04:11:27.006722+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T03:00:00+00:00 TriggerDagRunOperator 2023-05-28T04:11:29.099226+00:00 2023-05-28T04:11:29.547024+00:00 0:00:00.447798 387063 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T04:11:27.006755+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T03:00:00+00:00 EmrJobFlowSensor 2023-05-28T04:01:04.125735+00:00 2023-05-28T04:11:06.063954+00:00 0:10:01.938219 387056 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T04:01:02.158406+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T03:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T04:00:42.214221+00:00 2023-05-28T04:00:43.264455+00:00 0:00:01.050234 387055 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T04:00:40.135510+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T03:00:00+00:00 PythonOperator 2023-05-28T04:00:22.489134+00:00 2023-05-28T04:00:23.391946+00:00 0:00:00.902812 387053 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T04:00:20.119043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T02:00:00+00:00 TriggerDagRunOperator 2023-05-28T03:14:34.489659+00:00 2023-05-28T03:14:34.905523+00:00 0:00:00.415864 387043 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T03:14:32.219820+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T02:00:00+00:00 TriggerDagRunOperator 2023-05-28T03:14:34.365175+00:00 2023-05-28T03:14:34.812338+00:00 0:00:00.447163 387042 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T03:14:32.219849+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T02:00:00+00:00 EmrJobFlowSensor 2023-05-28T03:02:06.850546+00:00 2023-05-28T03:12:08.562327+00:00 0:10:01.711781 387035 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T03:02:04.843745+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T02:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T03:01:46.891247+00:00 2023-05-28T03:01:47.860913+00:00 0:00:00.969666 387034 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T03:01:44.827296+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T02:00:00+00:00 PythonOperator 2023-05-28T03:01:24.961814+00:00 2023-05-28T03:01:26.262670+00:00 0:00:01.300856 387031 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T03:01:22.805575+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T01:00:00+00:00 TriggerDagRunOperator 2023-05-28T02:14:38.787444+00:00 2023-05-28T02:14:39.231866+00:00 0:00:00.444422 387021 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T02:14:36.564662+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T01:00:00+00:00 TriggerDagRunOperator 2023-05-28T02:14:38.780850+00:00 2023-05-28T02:14:39.234620+00:00 0:00:00.453770 387020 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T02:14:36.564689+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T01:00:00+00:00 EmrJobFlowSensor 2023-05-28T02:04:12.737457+00:00 2023-05-28T02:14:14.512104+00:00 0:10:01.774647 387014 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T02:04:10.652737+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T01:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T02:03:51.476743+00:00 2023-05-28T02:03:52.454749+00:00 0:00:00.978006 387012 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T02:03:48.631915+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T01:00:00+00:00 PythonOperator 2023-05-28T02:03:30.610580+00:00 2023-05-28T02:03:31.603803+00:00 0:00:00.993223 387010 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T02:03:28.611937+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-28T00:00:00+00:00 TriggerDagRunOperator 2023-05-28T01:12:31.213847+00:00 2023-05-28T01:12:31.617783+00:00 0:00:00.403936 386990 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T01:12:28.988160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-28T00:00:00+00:00 TriggerDagRunOperator 2023-05-28T01:12:31.212369+00:00 2023-05-28T01:12:31.650668+00:00 0:00:00.438299 386989 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T01:12:28.988189+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-28T00:00:00+00:00 EmrJobFlowSensor 2023-05-28T01:02:24.959294+00:00 2023-05-28T01:12:26.636995+00:00 0:10:01.677701 386982 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T01:02:22.828405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-28T00:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T01:02:04.858304+00:00 2023-05-28T01:02:05.756731+00:00 0:00:00.898427 386980 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T01:02:02.808375+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-28T00:00:00+00:00 PythonOperator 2023-05-28T01:01:42.914854+00:00 2023-05-28T01:01:43.838853+00:00 0:00:00.923999 386978 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T01:01:40.790152+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T23:00:00+00:00 TriggerDagRunOperator 2023-05-28T00:11:24.034527+00:00 2023-05-28T00:11:24.463641+00:00 0:00:00.429114 386968 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T00:11:22.001516+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T23:00:00+00:00 TriggerDagRunOperator 2023-05-28T00:11:24.001580+00:00 2023-05-28T00:11:24.477722+00:00 0:00:00.476142 386967 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-28T00:11:22.001485+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T23:00:00+00:00 EmrJobFlowSensor 2023-05-28T00:01:04.851472+00:00 2023-05-28T00:11:06.695809+00:00 0:10:01.844337 386961 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-28T00:01:02.696017+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T23:00:00+00:00 EmrCreateJobFlowOperator 2023-05-28T00:00:45.430984+00:00 2023-05-28T00:00:46.298821+00:00 0:00:00.867837 386959 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-28T00:00:42.692604+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T23:00:00+00:00 PythonOperator 2023-05-28T00:00:23.218366+00:00 2023-05-28T00:00:24.094059+00:00 0:00:00.875693 386957 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-28T00:00:20.704527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T22:00:00+00:00 TriggerDagRunOperator 2023-05-27T23:11:18.504789+00:00 2023-05-27T23:11:18.967069+00:00 0:00:00.462280 386945 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T23:11:16.432756+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T22:00:00+00:00 TriggerDagRunOperator 2023-05-27T23:11:18.470354+00:00 2023-05-27T23:11:18.879339+00:00 0:00:00.408985 386944 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T23:11:16.432725+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T22:00:00+00:00 EmrJobFlowSensor 2023-05-27T23:00:54.000179+00:00 2023-05-27T23:10:55.807078+00:00 0:10:01.806899 386936 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T23:00:52.071944+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T22:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T23:00:32.110373+00:00 2023-05-27T23:00:32.993704+00:00 0:00:00.883331 386933 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T23:00:30.064198+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T22:00:00+00:00 PythonOperator 2023-05-27T23:00:10.558444+00:00 2023-05-27T23:00:11.592716+00:00 0:00:01.034272 386930 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T23:00:08.084426+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T21:00:00+00:00 TriggerDagRunOperator 2023-05-27T22:11:06.697741+00:00 2023-05-27T22:11:07.211098+00:00 0:00:00.513357 386919 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T22:11:04.716817+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T21:00:00+00:00 TriggerDagRunOperator 2023-05-27T22:11:06.701394+00:00 2023-05-27T22:11:07.143235+00:00 0:00:00.441841 386918 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T22:11:04.716791+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T21:00:00+00:00 EmrJobFlowSensor 2023-05-27T22:00:55.932731+00:00 2023-05-27T22:10:57.910452+00:00 0:10:01.977721 386911 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T22:00:53.889634+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T21:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T22:00:31.925142+00:00 2023-05-27T22:00:32.807048+00:00 0:00:00.881906 386909 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T22:00:29.886459+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T21:00:00+00:00 PythonOperator 2023-05-27T22:00:10.253301+00:00 2023-05-27T22:00:11.109496+00:00 0:00:00.856195 386907 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T22:00:07.809183+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T20:00:00+00:00 TriggerDagRunOperator 2023-05-27T21:11:21.600825+00:00 2023-05-27T21:11:22.021461+00:00 0:00:00.420636 386896 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T21:11:19.518329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T20:00:00+00:00 TriggerDagRunOperator 2023-05-27T21:11:21.553093+00:00 2023-05-27T21:11:22.042761+00:00 0:00:00.489668 386895 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T21:11:19.518357+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T20:00:00+00:00 EmrJobFlowSensor 2023-05-27T21:01:00.146392+00:00 2023-05-27T21:11:02.024520+00:00 0:10:01.878128 386889 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T21:00:57.509669+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T20:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T21:00:39.433424+00:00 2023-05-27T21:00:40.339225+00:00 0:00:00.905801 386887 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T21:00:37.487163+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T20:00:00+00:00 PythonOperator 2023-05-27T21:00:17.497030+00:00 2023-05-27T21:00:18.359454+00:00 0:00:00.862424 386885 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T21:00:15.468054+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T19:00:00+00:00 TriggerDagRunOperator 2023-05-27T20:11:23.475146+00:00 2023-05-27T20:11:23.935739+00:00 0:00:00.460593 386873 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T20:11:21.378728+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T19:00:00+00:00 TriggerDagRunOperator 2023-05-27T20:11:23.469453+00:00 2023-05-27T20:11:23.907775+00:00 0:00:00.438322 386872 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T20:11:21.378758+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T19:00:00+00:00 EmrJobFlowSensor 2023-05-27T20:01:04.911301+00:00 2023-05-27T20:11:06.858606+00:00 0:10:01.947305 386866 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T20:01:02.914083+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T19:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T20:00:45.091656+00:00 2023-05-27T20:00:46.182198+00:00 0:00:01.090542 386864 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T20:00:42.893449+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T19:00:00+00:00 PythonOperator 2023-05-27T20:00:22.962662+00:00 2023-05-27T20:00:23.875176+00:00 0:00:00.912514 386862 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T20:00:20.871881+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T18:00:00+00:00 TriggerDagRunOperator 2023-05-27T19:11:09.079868+00:00 2023-05-27T19:11:09.532061+00:00 0:00:00.452193 386848 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T19:11:07.000644+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T18:00:00+00:00 TriggerDagRunOperator 2023-05-27T19:11:09.050222+00:00 2023-05-27T19:11:09.483300+00:00 0:00:00.433078 386847 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T19:11:07.000677+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T18:00:00+00:00 EmrJobFlowSensor 2023-05-27T19:00:58.661837+00:00 2023-05-27T19:11:00.483846+00:00 0:10:01.822009 386840 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T19:00:56.622121+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T18:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T19:00:36.665933+00:00 2023-05-27T19:00:37.637333+00:00 0:00:00.971400 386839 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T19:00:34.601320+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T18:00:00+00:00 PythonOperator 2023-05-27T19:00:15.068579+00:00 2023-05-27T19:00:15.972289+00:00 0:00:00.903710 386837 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T19:00:12.594015+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T17:00:00+00:00 TriggerDagRunOperator 2023-05-27T18:12:37.360444+00:00 2023-05-27T18:12:37.799860+00:00 0:00:00.439416 386825 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T18:12:34.869727+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T17:00:00+00:00 TriggerDagRunOperator 2023-05-27T18:12:37.335359+00:00 2023-05-27T18:12:37.763607+00:00 0:00:00.428248 386824 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T18:12:34.869694+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T17:00:00+00:00 EmrJobFlowSensor 2023-05-27T18:01:06.996403+00:00 2023-05-27T18:12:09.063361+00:00 0:11:02.066958 386816 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T18:01:04.944549+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T17:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T18:00:45.110524+00:00 2023-05-27T18:00:46.040010+00:00 0:00:00.929486 386815 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T18:00:42.919955+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T17:00:00+00:00 PythonOperator 2023-05-27T18:00:22.970626+00:00 2023-05-27T18:00:23.864740+00:00 0:00:00.894114 386814 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T18:00:20.900363+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T16:00:00+00:00 TriggerDagRunOperator 2023-05-27T17:21:24.540658+00:00 2023-05-27T17:21:25.008560+00:00 0:00:00.467902 386804 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T17:21:22.172883+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T16:00:00+00:00 TriggerDagRunOperator 2023-05-27T17:21:24.525900+00:00 2023-05-27T17:21:25.014356+00:00 0:00:00.488456 386803 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T17:21:22.172857+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T16:00:00+00:00 EmrJobFlowSensor 2023-05-27T17:07:38.359326+00:00 2023-05-27T17:17:40.095237+00:00 0:10:01.735911 386797 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T17:07:36.283584+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T16:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T17:07:16.240344+00:00 2023-05-27T17:07:17.141126+00:00 0:00:00.900782 386794 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T17:07:14.252640+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T16:00:00+00:00 PythonOperator 2023-05-27T17:00:12.467332+00:00 2023-05-27T17:00:13.625879+00:00 0:00:01.158547 386791 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T17:00:10.341898+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T15:00:00+00:00 TriggerDagRunOperator 2023-05-27T16:20:10.282221+00:00 2023-05-27T16:20:10.739538+00:00 0:00:00.457317 386781 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T16:20:08.111405+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T15:00:00+00:00 TriggerDagRunOperator 2023-05-27T16:20:10.249094+00:00 2023-05-27T16:20:10.680288+00:00 0:00:00.431194 386780 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T16:20:08.111432+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T15:00:00+00:00 EmrJobFlowSensor 2023-05-27T16:09:50.748585+00:00 2023-05-27T16:19:52.722413+00:00 0:10:01.973828 386775 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T16:09:48.719661+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T15:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T16:09:28.731953+00:00 2023-05-27T16:09:29.668638+00:00 0:00:00.936685 386772 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T16:09:26.697545+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T15:00:00+00:00 PythonOperator 2023-05-27T16:09:09.122326+00:00 2023-05-27T16:09:10.048412+00:00 0:00:00.926086 386769 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T16:09:06.681724+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T14:00:00+00:00 TriggerDagRunOperator 2023-05-27T15:16:13.411353+00:00 2023-05-27T15:16:13.840127+00:00 0:00:00.428774 386761 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T15:16:11.220175+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T14:00:00+00:00 TriggerDagRunOperator 2023-05-27T15:16:13.355472+00:00 2023-05-27T15:16:13.771704+00:00 0:00:00.416232 386760 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T15:16:11.220202+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T14:00:00+00:00 EmrJobFlowSensor 2023-05-27T15:03:51.202612+00:00 2023-05-27T15:13:53.031302+00:00 0:10:01.828690 386754 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T15:03:48.872792+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T14:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T15:03:28.874064+00:00 2023-05-27T15:03:29.867018+00:00 0:00:00.992954 386751 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T15:03:26.846111+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T14:00:00+00:00 PythonOperator 2023-05-27T15:03:09.580904+00:00 2023-05-27T15:03:10.460952+00:00 0:00:00.880048 386750 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T15:03:06.884738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T13:00:00+00:00 TriggerDagRunOperator 2023-05-27T14:12:56.578284+00:00 2023-05-27T14:12:57.013921+00:00 0:00:00.435637 386740 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T14:12:54.104451+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T13:00:00+00:00 TriggerDagRunOperator 2023-05-27T14:12:56.549280+00:00 2023-05-27T14:12:57.049269+00:00 0:00:00.499989 386739 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T14:12:54.104480+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T13:00:00+00:00 EmrJobFlowSensor 2023-05-27T14:02:51.251269+00:00 2023-05-27T14:12:53.004847+00:00 0:10:01.753578 386733 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T14:02:49.180932+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T13:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T14:02:31.202616+00:00 2023-05-27T14:02:32.153815+00:00 0:00:00.951199 386731 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T14:02:29.165137+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T13:00:00+00:00 PythonOperator 2023-05-27T14:02:09.145137+00:00 2023-05-27T14:02:10.092172+00:00 0:00:00.947035 386729 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T14:02:07.140556+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T12:00:00+00:00 TriggerDagRunOperator 2023-05-27T13:16:19.853040+00:00 2023-05-27T13:16:20.283589+00:00 0:00:00.430549 386721 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T13:16:17.363160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T12:00:00+00:00 TriggerDagRunOperator 2023-05-27T13:16:19.693693+00:00 2023-05-27T13:16:20.107470+00:00 0:00:00.413777 386720 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T13:16:17.363130+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T12:00:00+00:00 EmrJobFlowSensor 2023-05-27T13:03:53.545212+00:00 2023-05-27T13:13:55.151890+00:00 0:10:01.606678 386713 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T13:03:51.555189+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T12:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T13:03:31.589151+00:00 2023-05-27T13:03:32.519046+00:00 0:00:00.929895 386711 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T13:03:29.534962+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T12:00:00+00:00 PythonOperator 2023-05-27T13:03:11.934977+00:00 2023-05-27T13:03:13.448669+00:00 0:00:01.513692 386709 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T13:03:09.570250+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T11:00:00+00:00 TriggerDagRunOperator 2023-05-27T12:27:48.535374+00:00 2023-05-27T12:27:49.050744+00:00 0:00:00.515370 386701 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T12:27:46.113911+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T11:00:00+00:00 TriggerDagRunOperator 2023-05-27T12:27:48.374542+00:00 2023-05-27T12:27:48.820186+00:00 0:00:00.445644 386700 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T12:27:46.113941+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T11:00:00+00:00 EmrJobFlowSensor 2023-05-27T12:02:33.629589+00:00 2023-05-27T12:12:35.454905+00:00 0:10:01.825316 386694 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T12:02:31.646656+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-05-27T11:00:00+00:00 EmrCreateJobFlowOperator 2023-05-27T12:02:11.656006+00:00 2023-05-27T12:02:12.595459+00:00 0:00:00.939453 386691 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 4 default 2023-05-27T12:02:09.625865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-05-27T11:00:00+00:00 PythonOperator 2023-05-27T12:01:51.746639+00:00 2023-05-27T12:01:52.657376+00:00 0:00:00.910737 386690 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 5 default 2023-05-27T12:01:49.610619+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-05-27T10:00:00+00:00 TriggerDagRunOperator 2023-05-27T11:12:41.509783+00:00 2023-05-27T11:12:42.142480+00:00 0:00:00.632697 386681 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T11:12:39.109429+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-05-27T10:00:00+00:00 TriggerDagRunOperator 2023-05-27T11:12:41.388495+00:00 2023-05-27T11:12:41.867342+00:00 0:00:00.478847 386680 airflow-worker-1.airflow-worker.data-eng.svc.cluster.local airflow 1 default 2023-05-27T11:12:39.109457+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-05-27T10:00:00+00:00 EmrJobFlowSensor 2023-05-27T11:02:17.903563+00:00 2023-05-27T11:12:19.694641+00:00 0:10:01.791078 386674 airflow-worker-0.airflow-worker.data-eng.svc.cluster.local airflow 3 default 2023-05-27T11:02:15.794852+00:00 2 default_pool