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 check_cluster_status 2023-03-08T03:00:00+00:00 EmrJobFlowSensor 2023-03-08T04:01:50.334955+00:00 2023-03-08T04:11:52.107486+00:00 0:10:01.772531 350073 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T04:01:47.635081+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T04:01:28.116421+00:00 2023-03-08T04:01:28.983266+00:00 0:00:00.866845 350071 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T04:01:25.593976+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T03:00:00+00:00 PythonOperator 2023-03-08T04:01:08.080127+00:00 2023-03-08T04:01:12.224017+00:00 0:00:04.143890 350069 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T04:01:05.616346+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T02:00:00+00:00 TriggerDagRunOperator 2023-03-08T03:11:50.109421+00:00 2023-03-08T03:11:50.623917+00:00 0:00:00.514496 350058 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T03:11:47.472065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T02:00:00+00:00 TriggerDagRunOperator 2023-03-08T03:11:50.074590+00:00 2023-03-08T03:11:50.575362+00:00 0:00:00.500772 350057 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T03:11:47.472093+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T02:00:00+00:00 EmrJobFlowSensor 2023-03-08T03:01:02.387469+00:00 2023-03-08T03:11:04.153560+00:00 0:10:01.766091 350050 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T03:01:00.138214+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T03:00:40.246132+00:00 2023-03-08T03:00:41.090557+00:00 0:00:00.844425 350048 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T03:00:38.031924+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T02:00:00+00:00 PythonOperator 2023-03-08T03:00:18.254182+00:00 2023-03-08T03:00:22.614647+00:00 0:00:04.360465 350046 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T03:00:15.991380+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T01:00:00+00:00 TriggerDagRunOperator 2023-03-08T02:11:13.579816+00:00 2023-03-08T02:11:14.056789+00:00 0:00:00.476973 350035 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T02:11:11.082083+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T01:00:00+00:00 TriggerDagRunOperator 2023-03-08T02:11:13.412224+00:00 2023-03-08T02:11:13.879937+00:00 0:00:00.467713 350034 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T02:11:11.082113+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T01:00:00+00:00 EmrJobFlowSensor 2023-03-08T02:01:02.974816+00:00 2023-03-08T02:11:04.771994+00:00 0:10:01.797178 350027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T02:01:00.514540+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T02:00:40.683078+00:00 2023-03-08T02:00:41.553874+00:00 0:00:00.870796 350025 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T02:00:38.479371+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T01:00:00+00:00 PythonOperator 2023-03-08T02:00:20.708613+00:00 2023-03-08T02:00:23.955312+00:00 0:00:03.246699 350023 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T02:00:18.461166+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-08T00:00:00+00:00 TriggerDagRunOperator 2023-03-08T01:11:06.331534+00:00 2023-03-08T01:11:06.833855+00:00 0:00:00.502321 350006 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T01:11:04.010538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-08T00:00:00+00:00 TriggerDagRunOperator 2023-03-08T01:11:06.275216+00:00 2023-03-08T01:11:06.731564+00:00 0:00:00.456348 350005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T01:11:04.010508+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-08T00:00:00+00:00 EmrJobFlowSensor 2023-03-08T01:00:50.563142+00:00 2023-03-08T01:10:52.445528+00:00 0:10:01.882386 349998 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T01:00:48.376244+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-08T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T01:00:30.743354+00:00 2023-03-08T01:00:31.637897+00:00 0:00:00.894543 349996 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T01:00:28.359223+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-08T00:00:00+00:00 PythonOperator 2023-03-08T01:00:08.880317+00:00 2023-03-08T01:00:12.808941+00:00 0:00:03.928624 349994 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T01:00:06.340385+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T23:00:00+00:00 TriggerDagRunOperator 2023-03-08T00:11:16.017411+00:00 2023-03-08T00:11:16.588719+00:00 0:00:00.571308 349982 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T00:11:13.731841+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T23:00:00+00:00 TriggerDagRunOperator 2023-03-08T00:11:15.985439+00:00 2023-03-08T00:11:16.563080+00:00 0:00:00.577641 349981 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-08T00:11:13.731813+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T23:00:00+00:00 EmrJobFlowSensor 2023-03-08T00:00:58.457770+00:00 2023-03-08T00:11:00.268122+00:00 0:10:01.810352 349974 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-08T00:00:56.232406+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-08T00:00:38.430045+00:00 2023-03-08T00:00:39.261497+00:00 0:00:00.831452 349972 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-08T00:00:36.213444+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T23:00:00+00:00 PythonOperator 2023-03-08T00:00:16.528142+00:00 2023-03-08T00:00:20.460279+00:00 0:00:03.932137 349970 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-08T00:00:14.205180+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T22:00:00+00:00 TriggerDagRunOperator 2023-03-07T23:11:03.826274+00:00 2023-03-07T23:11:04.334147+00:00 0:00:00.507873 349959 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T23:11:00.514636+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T22:00:00+00:00 TriggerDagRunOperator 2023-03-07T23:11:02.833703+00:00 2023-03-07T23:11:03.300162+00:00 0:00:00.466459 349958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T23:11:00.514669+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T22:00:00+00:00 EmrJobFlowSensor 2023-03-07T23:00:52.595909+00:00 2023-03-07T23:10:54.356707+00:00 0:10:01.760798 349951 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T23:00:50.252102+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T23:00:30.501424+00:00 2023-03-07T23:00:31.468824+00:00 0:00:00.967400 349948 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T23:00:28.235620+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T22:00:00+00:00 PythonOperator 2023-03-07T23:00:11.114428+00:00 2023-03-07T23:00:15.165483+00:00 0:00:04.051055 349945 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T23:00:08.199588+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T21:00:00+00:00 TriggerDagRunOperator 2023-03-07T22:11:14.547670+00:00 2023-03-07T22:11:15.277141+00:00 0:00:00.729471 349933 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T22:11:12.028634+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T21:00:00+00:00 TriggerDagRunOperator 2023-03-07T22:11:14.278062+00:00 2023-03-07T22:11:15.054851+00:00 0:00:00.776789 349932 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T22:11:12.028671+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T21:00:00+00:00 EmrJobFlowSensor 2023-03-07T22:00:50.761564+00:00 2023-03-07T22:10:52.685510+00:00 0:10:01.923946 349926 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T22:00:48.068588+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T22:00:28.252363+00:00 2023-03-07T22:00:29.077980+00:00 0:00:00.825617 349924 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T22:00:26.011727+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T21:00:00+00:00 PythonOperator 2023-03-07T22:00:06.434578+00:00 2023-03-07T22:00:10.355851+00:00 0:00:03.921273 349921 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T22:00:03.995802+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T20:00:00+00:00 TriggerDagRunOperator 2023-03-07T21:11:08.705239+00:00 2023-03-07T21:11:09.194381+00:00 0:00:00.489142 349910 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T21:11:06.286662+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T20:00:00+00:00 TriggerDagRunOperator 2023-03-07T21:11:08.591475+00:00 2023-03-07T21:11:09.071205+00:00 0:00:00.479730 349909 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T21:11:06.286626+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T20:00:00+00:00 EmrJobFlowSensor 2023-03-07T21:00:54.090050+00:00 2023-03-07T21:10:56.034230+00:00 0:10:01.944180 349902 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T21:00:51.737540+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T21:00:31.930229+00:00 2023-03-07T21:00:32.751615+00:00 0:00:00.821386 349900 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T21:00:29.704580+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T20:00:00+00:00 PythonOperator 2023-03-07T21:00:12.342643+00:00 2023-03-07T21:00:18.301804+00:00 0:00:05.959161 349898 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T21:00:09.690114+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T19:00:00+00:00 TriggerDagRunOperator 2023-03-07T20:11:03.190152+00:00 2023-03-07T20:11:03.688566+00:00 0:00:00.498414 349887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T20:11:00.410175+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T19:00:00+00:00 TriggerDagRunOperator 2023-03-07T20:11:03.164196+00:00 2023-03-07T20:11:03.714730+00:00 0:00:00.550534 349886 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T20:11:00.410224+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T19:00:00+00:00 EmrJobFlowSensor 2023-03-07T20:00:50.298459+00:00 2023-03-07T20:10:52.530834+00:00 0:10:02.232375 349879 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T20:00:45.639373+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T20:00:25.755757+00:00 2023-03-07T20:00:26.669646+00:00 0:00:00.913889 349877 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T20:00:23.550120+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T19:00:00+00:00 PythonOperator 2023-03-07T20:00:05.896553+00:00 2023-03-07T20:00:09.279750+00:00 0:00:03.383197 349875 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T20:00:03.530842+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T18:00:00+00:00 TriggerDagRunOperator 2023-03-07T19:11:30.530738+00:00 2023-03-07T19:11:31.089663+00:00 0:00:00.558925 349865 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T19:11:27.490387+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T18:00:00+00:00 TriggerDagRunOperator 2023-03-07T19:11:30.237564+00:00 2023-03-07T19:11:30.841338+00:00 0:00:00.603774 349864 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T19:11:27.490358+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T18:00:00+00:00 EmrJobFlowSensor 2023-03-07T19:01:04.615108+00:00 2023-03-07T19:11:06.478028+00:00 0:10:01.862920 349857 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T19:01:02.115673+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T19:00:42.354776+00:00 2023-03-07T19:00:43.242065+00:00 0:00:00.887289 349855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T19:00:40.023306+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T18:00:00+00:00 PythonOperator 2023-03-07T19:00:18.909320+00:00 2023-03-07T19:00:22.314782+00:00 0:00:03.405462 349853 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T19:00:16.011364+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T17:00:00+00:00 TriggerDagRunOperator 2023-03-07T18:11:33.412769+00:00 2023-03-07T18:11:34.015115+00:00 0:00:00.602346 349841 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T18:11:30.245812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T17:00:00+00:00 TriggerDagRunOperator 2023-03-07T18:11:33.200967+00:00 2023-03-07T18:11:33.678623+00:00 0:00:00.477656 349840 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T18:11:30.245763+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T17:00:00+00:00 EmrJobFlowSensor 2023-03-07T18:00:56.454513+00:00 2023-03-07T18:10:58.240125+00:00 0:10:01.785612 349832 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T18:00:53.707257+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T17:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T18:00:34.270603+00:00 2023-03-07T18:00:35.152118+00:00 0:00:00.881515 349830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T18:00:31.690843+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T17:00:00+00:00 PythonOperator 2023-03-07T18:00:12.127079+00:00 2023-03-07T18:00:15.652202+00:00 0:00:03.525123 349828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T18:00:09.596456+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T16:00:00+00:00 TriggerDagRunOperator 2023-03-07T17:11:01.417844+00:00 2023-03-07T17:11:02.007143+00:00 0:00:00.589299 349817 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T17:10:58.965260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T16:00:00+00:00 TriggerDagRunOperator 2023-03-07T17:11:01.256757+00:00 2023-03-07T17:11:01.748536+00:00 0:00:00.491779 349816 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T17:10:58.965296+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T16:00:00+00:00 EmrJobFlowSensor 2023-03-07T17:00:53.041424+00:00 2023-03-07T17:10:54.984897+00:00 0:10:01.943473 349809 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T17:00:48.202528+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T16:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T17:00:28.447588+00:00 2023-03-07T17:00:29.234073+00:00 0:00:00.786485 349807 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T17:00:26.126529+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T16:00:00+00:00 PythonOperator 2023-03-07T17:00:06.544984+00:00 2023-03-07T17:00:09.514475+00:00 0:00:02.969491 349805 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T17:00:04.093764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T15:00:00+00:00 TriggerDagRunOperator 2023-03-07T16:19:21.039326+00:00 2023-03-07T16:19:21.552767+00:00 0:00:00.513441 349797 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T16:19:18.427090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T15:00:00+00:00 TriggerDagRunOperator 2023-03-07T16:19:20.828269+00:00 2023-03-07T16:19:21.335930+00:00 0:00:00.507661 349796 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T16:19:18.427060+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T15:00:00+00:00 EmrJobFlowSensor 2023-03-07T16:09:01.861160+00:00 2023-03-07T16:19:03.759632+00:00 0:10:01.898472 349792 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T16:08:59.419169+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T15:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T16:08:39.858914+00:00 2023-03-07T16:08:41.494918+00:00 0:00:01.636004 349789 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T16:08:37.359803+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T15:00:00+00:00 PythonOperator 2023-03-07T16:08:21.647858+00:00 2023-03-07T16:08:25.839000+00:00 0:00:04.191142 349787 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T16:08:17.340850+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T14:00:00+00:00 TriggerDagRunOperator 2023-03-07T15:19:14.568824+00:00 2023-03-07T15:19:15.292106+00:00 0:00:00.723282 349777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T15:19:11.840036+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T14:00:00+00:00 TriggerDagRunOperator 2023-03-07T15:19:14.496427+00:00 2023-03-07T15:19:15.273971+00:00 0:00:00.777544 349776 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T15:19:11.840007+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T14:00:00+00:00 EmrJobFlowSensor 2023-03-07T15:08:52.005753+00:00 2023-03-07T15:18:54.016112+00:00 0:10:02.010359 349772 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T15:08:49.728498+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T14:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T15:08:30.124295+00:00 2023-03-07T15:08:31.797245+00:00 0:00:01.672950 349769 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T15:08:27.689440+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T14:00:00+00:00 PythonOperator 2023-03-07T15:08:10.591498+00:00 2023-03-07T15:08:13.802830+00:00 0:00:03.211332 349766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T15:08:07.669462+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T13:00:00+00:00 TriggerDagRunOperator 2023-03-07T14:20:16.446074+00:00 2023-03-07T14:20:16.927746+00:00 0:00:00.481672 349758 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T14:20:13.806006+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T13:00:00+00:00 TriggerDagRunOperator 2023-03-07T14:20:16.345880+00:00 2023-03-07T14:20:16.820175+00:00 0:00:00.474295 349757 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T14:20:13.805976+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T13:00:00+00:00 EmrJobFlowSensor 2023-03-07T14:10:08.060746+00:00 2023-03-07T14:20:09.862848+00:00 0:10:01.802102 349752 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T14:10:05.719258+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T14:09:47.488197+00:00 2023-03-07T14:09:49.397307+00:00 0:00:01.909110 349748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T14:09:43.940961+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T13:00:00+00:00 PythonOperator 2023-03-07T14:09:26.897813+00:00 2023-03-07T14:09:34.048656+00:00 0:00:07.150843 349744 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T14:09:21.643004+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T12:00:00+00:00 TriggerDagRunOperator 2023-03-07T14:09:26.745680+00:00 2023-03-07T14:09:27.896113+00:00 0:00:01.150433 349743 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T14:09:21.642942+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T12:00:00+00:00 TriggerDagRunOperator 2023-03-07T14:09:23.907638+00:00 2023-03-07T14:09:24.337054+00:00 0:00:00.429416 349742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T14:09:21.643028+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T12:00:00+00:00 EmrJobFlowSensor 2023-03-07T13:19:49.585086+00:00 2023-03-07T13:29:51.404310+00:00 0:10:01.819224 349736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T13:19:47.031938+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T13:19:29.442246+00:00 2023-03-07T13:19:30.296919+00:00 0:00:00.854673 349733 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T13:19:26.940619+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T12:00:00+00:00 PythonOperator 2023-03-07T13:19:07.652154+00:00 2023-03-07T13:19:11.674583+00:00 0:00:04.022429 349730 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T13:19:04.917902+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T11:00:00+00:00 TriggerDagRunOperator 2023-03-07T12:11:07.287851+00:00 2023-03-07T12:11:07.775106+00:00 0:00:00.487255 349720 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T12:11:04.915214+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T11:00:00+00:00 TriggerDagRunOperator 2023-03-07T12:11:07.145549+00:00 2023-03-07T12:11:07.593444+00:00 0:00:00.447895 349719 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T12:11:04.915242+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T11:00:00+00:00 EmrJobFlowSensor 2023-03-07T12:00:52.449591+00:00 2023-03-07T12:10:54.280300+00:00 0:10:01.830709 349713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T12:00:49.732321+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T12:00:29.956089+00:00 2023-03-07T12:00:30.998330+00:00 0:00:01.042241 349711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T12:00:27.690131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T11:00:00+00:00 PythonOperator 2023-03-07T12:00:09.877409+00:00 2023-03-07T12:00:13.827427+00:00 0:00:03.950018 349709 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T12:00:07.680608+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T10:00:00+00:00 TriggerDagRunOperator 2023-03-07T11:14:00.877699+00:00 2023-03-07T11:14:01.434920+00:00 0:00:00.557221 349699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T11:13:58.366867+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T10:00:00+00:00 TriggerDagRunOperator 2023-03-07T11:14:00.830051+00:00 2023-03-07T11:14:01.402619+00:00 0:00:00.572568 349698 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T11:13:58.366839+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T10:00:00+00:00 EmrJobFlowSensor 2023-03-07T11:00:56.754386+00:00 2023-03-07T11:10:58.426371+00:00 0:10:01.671985 349691 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T11:00:54.487514+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T11:00:34.764719+00:00 2023-03-07T11:00:35.632533+00:00 0:00:00.867814 349689 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T11:00:32.344276+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T10:00:00+00:00 PythonOperator 2023-03-07T11:00:15.235284+00:00 2023-03-07T11:00:18.390520+00:00 0:00:03.155236 349688 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T11:00:12.325411+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T09:00:00+00:00 TriggerDagRunOperator 2023-03-07T10:30:18.686050+00:00 2023-03-07T10:30:19.222596+00:00 0:00:00.536546 349677 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T10:30:16.300921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T09:00:00+00:00 TriggerDagRunOperator 2023-03-07T10:30:18.670465+00:00 2023-03-07T10:30:19.174599+00:00 0:00:00.504134 349676 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T10:30:16.300960+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T09:00:00+00:00 EmrJobFlowSensor 2023-03-07T10:00:47.121594+00:00 2023-03-07T10:11:49.053430+00:00 0:11:01.931836 349671 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T10:00:44.760242+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T10:00:26.982325+00:00 2023-03-07T10:00:27.810133+00:00 0:00:00.827808 349669 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T10:00:24.738656+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T09:00:00+00:00 PythonOperator 2023-03-07T10:00:05.104188+00:00 2023-03-07T10:00:08.361797+00:00 0:00:03.257609 349667 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T10:00:02.635063+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T08:00:00+00:00 TriggerDagRunOperator 2023-03-07T09:11:18.309114+00:00 2023-03-07T09:11:19.262436+00:00 0:00:00.953322 349657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T09:11:16.002310+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T08:00:00+00:00 TriggerDagRunOperator 2023-03-07T09:11:18.214929+00:00 2023-03-07T09:11:18.729714+00:00 0:00:00.514785 349656 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T09:11:16.002280+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-07T08:00:00+00:00 EmrJobFlowSensor 2023-03-07T09:01:02.517712+00:00 2023-03-07T09:11:04.445915+00:00 0:10:01.928203 349651 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-07T09:00:59.824015+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-07T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-07T09:00:40.388424+00:00 2023-03-07T09:00:41.222471+00:00 0:00:00.834047 349649 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-07T09:00:37.813697+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-07T08:00:00+00:00 PythonOperator 2023-03-07T09:00:18.131490+00:00 2023-03-07T09:00:22.541304+00:00 0:00:04.409814 349647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-07T09:00:15.790770+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-07T07:00:00+00:00 TriggerDagRunOperator 2023-03-07T08:11:11.904752+00:00 2023-03-07T08:11:12.441407+00:00 0:00:00.536655 349638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T08:11:09.390876+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-07T07:00:00+00:00 TriggerDagRunOperator 2023-03-07T08:11:11.863618+00:00 2023-03-07T08:11:12.368731+00:00 0:00:00.505113 349637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-07T08:11:09.390915+00:00 2 default_pool