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-02-10T13:00:00+00:00 EmrJobFlowSensor 2023-02-10T14:00:57.481544+00:00 2023-02-10T14:10:59.369361+00:00 0:10:01.887817 337177 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T14:00:55.251879+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T13:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T14:00:35.557624+00:00 2023-02-10T14:00:36.399062+00:00 0:00:00.841438 337175 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T14:00:33.230729+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T13:00:00+00:00 PythonOperator 2023-02-10T14:00:13.467816+00:00 2023-02-10T14:00:17.304701+00:00 0:00:03.836885 337173 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T14:00:11.132738+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T12:00:00+00:00 TriggerDagRunOperator 2023-02-10T13:28:02.957424+00:00 2023-02-10T13:28:03.512527+00:00 0:00:00.555103 337162 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T13:28:00.143188+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T12:00:00+00:00 TriggerDagRunOperator 2023-02-10T13:28:02.827937+00:00 2023-02-10T13:28:03.370653+00:00 0:00:00.542716 337161 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T13:28:00.143218+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T12:00:00+00:00 EmrJobFlowSensor 2023-02-10T13:07:40.841248+00:00 2023-02-10T13:17:42.713813+00:00 0:10:01.872565 337156 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T13:07:38.510544+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T12:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T13:07:18.868513+00:00 2023-02-10T13:07:19.782742+00:00 0:00:00.914229 337153 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T13:07:16.460377+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T12:00:00+00:00 PythonOperator 2023-02-10T13:06:58.944136+00:00 2023-02-10T13:07:02.876462+00:00 0:00:03.932326 337150 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T13:06:56.482477+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T11:00:00+00:00 TriggerDagRunOperator 2023-02-10T12:14:32.630377+00:00 2023-02-10T12:14:33.224526+00:00 0:00:00.594149 337139 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T12:14:29.736227+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T11:00:00+00:00 TriggerDagRunOperator 2023-02-10T12:14:32.477050+00:00 2023-02-10T12:14:32.981062+00:00 0:00:00.504012 337138 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T12:14:29.736199+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T11:00:00+00:00 EmrJobFlowSensor 2023-02-10T12:01:16.360072+00:00 2023-02-10T12:11:18.323003+00:00 0:10:01.962931 337131 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T12:01:13.990880+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T11:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T12:00:56.371598+00:00 2023-02-10T12:00:57.313015+00:00 0:00:00.941417 337129 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T12:00:53.973943+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T11:00:00+00:00 PythonOperator 2023-02-10T12:00:34.968974+00:00 2023-02-10T12:00:38.022303+00:00 0:00:03.053329 337127 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T12:00:32.004514+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T10:00:00+00:00 TriggerDagRunOperator 2023-02-10T11:11:09.272327+00:00 2023-02-10T11:11:09.770602+00:00 0:00:00.498275 337115 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T11:11:06.565953+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T10:00:00+00:00 TriggerDagRunOperator 2023-02-10T11:11:08.970598+00:00 2023-02-10T11:11:09.428846+00:00 0:00:00.458248 337114 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T11:11:06.565992+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T10:00:00+00:00 EmrJobFlowSensor 2023-02-10T11:00:58.657906+00:00 2023-02-10T11:11:00.422111+00:00 0:10:01.764205 337107 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T11:00:56.483307+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T10:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T11:00:36.796134+00:00 2023-02-10T11:00:37.627400+00:00 0:00:00.831266 337105 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T11:00:34.463080+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T10:00:00+00:00 PythonOperator 2023-02-10T11:00:14.978855+00:00 2023-02-10T11:00:18.009099+00:00 0:00:03.030244 337103 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T11:00:12.496362+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T09:00:00+00:00 TriggerDagRunOperator 2023-02-10T10:23:43.580697+00:00 2023-02-10T10:23:44.048550+00:00 0:00:00.467853 337091 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T10:23:41.138065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T09:00:00+00:00 TriggerDagRunOperator 2023-02-10T10:23:43.487674+00:00 2023-02-10T10:23:43.928591+00:00 0:00:00.440917 337090 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T10:23:41.138036+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T09:00:00+00:00 EmrJobFlowSensor 2023-02-10T10:13:24.987032+00:00 2023-02-10T10:23:26.748336+00:00 0:10:01.761304 337087 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T10:13:22.832206+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T09:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T10:13:07.150868+00:00 2023-02-10T10:13:08.268440+00:00 0:00:01.117572 337084 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T10:13:02.779075+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T09:00:00+00:00 PythonOperator 2023-02-10T10:12:42.975106+00:00 2023-02-10T10:12:46.242198+00:00 0:00:03.267092 337081 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T10:12:40.760618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T08:00:00+00:00 TriggerDagRunOperator 2023-02-10T09:12:18.064956+00:00 2023-02-10T09:12:18.593979+00:00 0:00:00.529023 337066 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T09:12:15.577600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T08:00:00+00:00 TriggerDagRunOperator 2023-02-10T09:12:17.920794+00:00 2023-02-10T09:12:18.429412+00:00 0:00:00.508618 337065 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T09:12:15.577566+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T08:00:00+00:00 EmrJobFlowSensor 2023-02-10T09:00:52.918305+00:00 2023-02-10T09:11:54.976699+00:00 0:11:02.058394 337057 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T09:00:50.523510+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T08:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T09:00:30.706943+00:00 2023-02-10T09:00:31.621898+00:00 0:00:00.914955 337055 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T09:00:28.452453+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T08:00:00+00:00 PythonOperator 2023-02-10T09:00:10.859344+00:00 2023-02-10T09:00:14.605835+00:00 0:00:03.746491 337053 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T09:00:08.443260+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T07:00:00+00:00 TriggerDagRunOperator 2023-02-10T08:11:15.990931+00:00 2023-02-10T08:11:16.565974+00:00 0:00:00.575043 337040 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T08:11:13.468348+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T07:00:00+00:00 TriggerDagRunOperator 2023-02-10T08:11:15.950202+00:00 2023-02-10T08:11:16.465214+00:00 0:00:00.515012 337039 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T08:11:13.468378+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T07:00:00+00:00 EmrJobFlowSensor 2023-02-10T08:00:49.639802+00:00 2023-02-10T08:10:51.819503+00:00 0:10:02.179701 337031 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T08:00:47.232256+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T07:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T08:00:29.544047+00:00 2023-02-10T08:00:30.390647+00:00 0:00:00.846600 337029 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T08:00:27.194461+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T07:00:00+00:00 PythonOperator 2023-02-10T08:00:07.707699+00:00 2023-02-10T08:00:10.975133+00:00 0:00:03.267434 337027 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T08:00:05.174941+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T06:00:00+00:00 TriggerDagRunOperator 2023-02-10T07:11:17.925020+00:00 2023-02-10T07:11:18.436180+00:00 0:00:00.511160 337015 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T07:11:15.178932+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T06:00:00+00:00 TriggerDagRunOperator 2023-02-10T07:11:17.851160+00:00 2023-02-10T07:11:18.355165+00:00 0:00:00.504005 337014 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T07:11:15.178904+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T06:00:00+00:00 EmrJobFlowSensor 2023-02-10T07:01:03.120824+00:00 2023-02-10T07:11:04.956677+00:00 0:10:01.835853 337007 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T07:01:00.393281+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T06:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T07:00:40.535877+00:00 2023-02-10T07:00:41.351649+00:00 0:00:00.815772 337005 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T07:00:38.249721+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T06:00:00+00:00 PythonOperator 2023-02-10T07:00:20.405428+00:00 2023-02-10T07:00:23.476938+00:00 0:00:03.071510 337003 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T07:00:18.162454+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T05:00:00+00:00 TriggerDagRunOperator 2023-02-10T06:13:31.287683+00:00 2023-02-10T06:13:31.737682+00:00 0:00:00.449999 336990 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T06:13:28.493093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T05:00:00+00:00 TriggerDagRunOperator 2023-02-10T06:13:31.027269+00:00 2023-02-10T06:13:31.554865+00:00 0:00:00.527596 336989 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T06:13:28.493120+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T05:00:00+00:00 EmrJobFlowSensor 2023-02-10T06:01:00.567746+00:00 2023-02-10T06:11:02.572459+00:00 0:10:02.004713 336982 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T06:00:58.236912+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T05:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T06:00:38.337900+00:00 2023-02-10T06:00:39.207022+00:00 0:00:00.869122 336980 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T06:00:36.207238+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T05:00:00+00:00 PythonOperator 2023-02-10T06:00:18.625487+00:00 2023-02-10T06:00:24.487433+00:00 0:00:05.861946 336978 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T06:00:16.173757+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T04:00:00+00:00 TriggerDagRunOperator 2023-02-10T05:17:02.889327+00:00 2023-02-10T05:17:03.397652+00:00 0:00:00.508325 336966 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T05:16:59.957214+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T04:00:00+00:00 TriggerDagRunOperator 2023-02-10T05:17:02.859697+00:00 2023-02-10T05:17:03.368315+00:00 0:00:00.508618 336965 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T05:16:59.957247+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T04:00:00+00:00 EmrJobFlowSensor 2023-02-10T05:01:06.712705+00:00 2023-02-10T05:11:09.234055+00:00 0:10:02.521350 336958 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T05:01:04.437373+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T04:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T05:00:45.410704+00:00 2023-02-10T05:00:46.293544+00:00 0:00:00.882840 336956 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T05:00:42.427326+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T04:00:00+00:00 PythonOperator 2023-02-10T05:00:22.902553+00:00 2023-02-10T05:00:25.752464+00:00 0:00:02.849911 336954 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T05:00:20.368623+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T03:00:00+00:00 TriggerDagRunOperator 2023-02-10T04:11:28.768352+00:00 2023-02-10T04:11:29.267569+00:00 0:00:00.499217 336940 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T04:11:25.491193+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T03:00:00+00:00 TriggerDagRunOperator 2023-02-10T04:11:28.486135+00:00 2023-02-10T04:11:28.970174+00:00 0:00:00.484039 336939 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T04:11:25.491242+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T03:00:00+00:00 EmrJobFlowSensor 2023-02-10T04:01:03.705230+00:00 2023-02-10T04:11:05.550815+00:00 0:10:01.845585 336932 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T04:01:01.193961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T03:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T04:00:41.299283+00:00 2023-02-10T04:00:42.148520+00:00 0:00:00.849237 336930 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T04:00:39.083989+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T03:00:00+00:00 PythonOperator 2023-02-10T04:00:19.460481+00:00 2023-02-10T04:00:22.789862+00:00 0:00:03.329381 336928 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T04:00:16.995720+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T02:00:00+00:00 TriggerDagRunOperator 2023-02-10T03:11:01.849927+00:00 2023-02-10T03:11:02.353166+00:00 0:00:00.503239 336914 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T03:10:59.427314+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T02:00:00+00:00 TriggerDagRunOperator 2023-02-10T03:11:01.835839+00:00 2023-02-10T03:11:02.356963+00:00 0:00:00.521124 336913 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T03:10:59.427286+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T02:00:00+00:00 EmrJobFlowSensor 2023-02-10T03:00:48.569750+00:00 2023-02-10T03:10:50.439792+00:00 0:10:01.870042 336905 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T03:00:46.291869+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T02:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T03:00:28.464636+00:00 2023-02-10T03:00:29.280950+00:00 0:00:00.816314 336903 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T03:00:26.280605+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T02:00:00+00:00 PythonOperator 2023-02-10T03:00:06.761500+00:00 2023-02-10T03:00:10.619697+00:00 0:00:03.858197 336901 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T03:00:04.253074+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T01:00:00+00:00 TriggerDagRunOperator 2023-02-10T02:11:03.966877+00:00 2023-02-10T02:11:04.497064+00:00 0:00:00.530187 336888 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T02:11:01.425068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T01:00:00+00:00 TriggerDagRunOperator 2023-02-10T02:11:03.825792+00:00 2023-02-10T02:11:04.325259+00:00 0:00:00.499467 336887 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T02:11:01.425040+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T01:00:00+00:00 EmrJobFlowSensor 2023-02-10T02:00:54.977047+00:00 2023-02-10T02:10:56.952258+00:00 0:10:01.975211 336880 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T02:00:52.666620+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T01:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T02:00:33.312681+00:00 2023-02-10T02:00:34.163597+00:00 0:00:00.850916 336878 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T02:00:30.698736+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T01:00:00+00:00 PythonOperator 2023-02-10T02:00:11.150354+00:00 2023-02-10T02:00:14.194979+00:00 0:00:03.044625 336876 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T02:00:08.698166+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-10T00:00:00+00:00 TriggerDagRunOperator 2023-02-10T01:11:00.392462+00:00 2023-02-10T01:11:00.938187+00:00 0:00:00.545725 336856 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T01:10:57.838573+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-10T00:00:00+00:00 TriggerDagRunOperator 2023-02-10T01:11:00.286412+00:00 2023-02-10T01:11:00.768917+00:00 0:00:00.482505 336855 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T01:10:57.838601+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-10T00:00:00+00:00 EmrJobFlowSensor 2023-02-10T01:00:51.757590+00:00 2023-02-10T01:10:53.638433+00:00 0:10:01.880843 336847 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T01:00:49.383926+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-10T00:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T01:00:31.564663+00:00 2023-02-10T01:00:32.360970+00:00 0:00:00.796307 336845 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T01:00:29.346936+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-10T00:00:00+00:00 PythonOperator 2023-02-10T01:00:10.163637+00:00 2023-02-10T01:00:14.096284+00:00 0:00:03.932647 336843 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T01:00:07.400027+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T23:00:00+00:00 TriggerDagRunOperator 2023-02-10T00:11:20.608135+00:00 2023-02-10T00:11:21.142525+00:00 0:00:00.534390 336830 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T00:11:18.109207+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T23:00:00+00:00 TriggerDagRunOperator 2023-02-10T00:11:20.336721+00:00 2023-02-10T00:11:20.911230+00:00 0:00:00.574509 336829 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-10T00:11:18.109171+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T23:00:00+00:00 EmrJobFlowSensor 2023-02-10T00:00:56.696562+00:00 2023-02-10T00:10:58.521927+00:00 0:10:01.825365 336823 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-10T00:00:54.430768+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T23:00:00+00:00 EmrCreateJobFlowOperator 2023-02-10T00:00:36.545957+00:00 2023-02-10T00:00:37.379182+00:00 0:00:00.833225 336821 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-10T00:00:34.388111+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T23:00:00+00:00 PythonOperator 2023-02-10T00:00:14.992094+00:00 2023-02-10T00:00:17.879890+00:00 0:00:02.887796 336819 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-10T00:00:12.372095+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T22:00:00+00:00 TriggerDagRunOperator 2023-02-09T23:11:11.351289+00:00 2023-02-09T23:11:11.853643+00:00 0:00:00.502354 336804 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T23:11:09.041550+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T22:00:00+00:00 TriggerDagRunOperator 2023-02-09T23:11:11.312677+00:00 2023-02-09T23:11:11.792151+00:00 0:00:00.479474 336803 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T23:11:09.041502+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T22:00:00+00:00 EmrJobFlowSensor 2023-02-09T23:00:54.896127+00:00 2023-02-09T23:10:56.668084+00:00 0:10:01.771957 336795 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T23:00:52.336002+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T22:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T23:00:32.524346+00:00 2023-02-09T23:00:33.354613+00:00 0:00:00.830267 336792 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T23:00:30.364452+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T22:00:00+00:00 PythonOperator 2023-02-09T23:00:12.451146+00:00 2023-02-09T23:00:19.323707+00:00 0:00:06.872561 336789 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T23:00:10.255768+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T21:00:00+00:00 TriggerDagRunOperator 2023-02-09T22:11:14.794798+00:00 2023-02-09T22:11:15.392439+00:00 0:00:00.597641 336774 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T22:11:12.341383+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T21:00:00+00:00 TriggerDagRunOperator 2023-02-09T22:11:14.574542+00:00 2023-02-09T22:11:15.108838+00:00 0:00:00.534296 336773 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T22:11:12.341434+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T21:00:00+00:00 EmrJobFlowSensor 2023-02-09T22:00:49.535219+00:00 2023-02-09T22:10:51.509650+00:00 0:10:01.974431 336766 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T22:00:46.993790+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T21:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T22:00:29.308033+00:00 2023-02-09T22:00:30.233620+00:00 0:00:00.925587 336764 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T22:00:26.924012+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T21:00:00+00:00 PythonOperator 2023-02-09T22:00:07.412959+00:00 2023-02-09T22:00:10.406799+00:00 0:00:02.993840 336762 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T22:00:04.842078+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T20:00:00+00:00 TriggerDagRunOperator 2023-02-09T21:11:29.033743+00:00 2023-02-09T21:11:29.614884+00:00 0:00:00.581141 336748 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T21:11:26.130555+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T20:00:00+00:00 TriggerDagRunOperator 2023-02-09T21:11:28.902211+00:00 2023-02-09T21:11:29.359333+00:00 0:00:00.457122 336747 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T21:11:26.130596+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T20:00:00+00:00 EmrJobFlowSensor 2023-02-09T21:00:58.640474+00:00 2023-02-09T21:11:00.441045+00:00 0:10:01.800571 336739 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T21:00:56.086395+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T20:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T21:00:36.544703+00:00 2023-02-09T21:00:37.568754+00:00 0:00:01.024051 336737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T21:00:34.122785+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T20:00:00+00:00 PythonOperator 2023-02-09T21:00:15.080457+00:00 2023-02-09T21:00:20.746455+00:00 0:00:05.665998 336735 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T21:00:12.109160+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T19:00:00+00:00 TriggerDagRunOperator 2023-02-09T20:11:47.155612+00:00 2023-02-09T20:11:47.675456+00:00 0:00:00.519844 336721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T20:11:44.253658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T19:00:00+00:00 TriggerDagRunOperator 2023-02-09T20:11:46.990494+00:00 2023-02-09T20:11:47.491083+00:00 0:00:00.500589 336720 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T20:11:44.253624+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T19:00:00+00:00 EmrJobFlowSensor 2023-02-09T20:00:59.261620+00:00 2023-02-09T20:11:01.097084+00:00 0:10:01.835464 336712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T20:00:56.805559+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T19:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T20:00:39.112918+00:00 2023-02-09T20:00:39.977006+00:00 0:00:00.864088 336710 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T20:00:36.725929+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T19:00:00+00:00 PythonOperator 2023-02-09T20:00:17.146931+00:00 2023-02-09T20:00:20.938720+00:00 0:00:03.791789 336708 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T20:00:14.692265+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T18:00:00+00:00 TriggerDagRunOperator 2023-02-09T19:11:29.298255+00:00 2023-02-09T19:11:29.842028+00:00 0:00:00.543773 336695 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T19:11:26.022464+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T18:00:00+00:00 TriggerDagRunOperator 2023-02-09T19:11:29.110503+00:00 2023-02-09T19:11:29.631311+00:00 0:00:00.520808 336694 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T19:11:26.022411+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-02-09T18:00:00+00:00 EmrJobFlowSensor 2023-02-09T19:01:05.611776+00:00 2023-02-09T19:11:07.415415+00:00 0:10:01.803639 336687 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-02-09T19:01:03.138220+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-02-09T18:00:00+00:00 EmrCreateJobFlowOperator 2023-02-09T19:00:45.477372+00:00 2023-02-09T19:00:46.355356+00:00 0:00:00.877984 336685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-02-09T19:00:43.092568+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-02-09T18:00:00+00:00 PythonOperator 2023-02-09T19:00:23.409952+00:00 2023-02-09T19:00:26.300640+00:00 0:00:02.890688 336683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-02-09T19:00:21.055562+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-02-09T17:00:00+00:00 TriggerDagRunOperator 2023-02-09T18:10:58.911848+00:00 2023-02-09T18:10:59.397242+00:00 0:00:00.485394 336668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T18:10:56.552950+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-02-09T17:00:00+00:00 TriggerDagRunOperator 2023-02-09T18:10:58.846230+00:00 2023-02-09T18:10:59.327940+00:00 0:00:00.481710 336667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-02-09T18:10:56.553001+00:00 2 default_pool