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_emr_steps 2021-05-05T13:00:00+00:00 PythonOperator 2021-05-05T14:00:11.618914+00:00 2021-05-05T14:00:14.689151+00:00 0:00:03.070237 24751 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T14:00:09.171179+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T12:00:00+00:00 TriggerDagRunOperator 2021-05-05T13:11:00.355872+00:00 2021-05-05T13:11:00.872163+00:00 0:00:00.516291 24743 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T13:10:57.644412+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T12:00:00+00:00 TriggerDagRunOperator 2021-05-05T13:11:00.208179+00:00 2021-05-05T13:11:00.636430+00:00 0:00:00.428251 24742 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T13:10:57.644457+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T12:00:00+00:00 EmrJobFlowSensor 2021-05-05T13:00:50.814031+00:00 2021-05-05T13:10:53.692356+00:00 0:10:02.878325 24738 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T13:00:48.579803+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T13:00:28.604899+00:00 2021-05-05T13:00:30.362024+00:00 0:00:01.757125 24737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T13:00:26.517406+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T12:00:00+00:00 PythonOperator 2021-05-05T13:00:08.781446+00:00 2021-05-05T13:00:11.873840+00:00 0:00:03.092394 24736 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T13:00:06.487333+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T11:00:00+00:00 TriggerDagRunOperator 2021-05-05T12:10:21.199829+00:00 2021-05-05T12:10:21.627113+00:00 0:00:00.427284 24728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T12:10:18.713442+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T11:00:00+00:00 TriggerDagRunOperator 2021-05-05T12:10:20.995349+00:00 2021-05-05T12:10:21.521687+00:00 0:00:00.526338 24727 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T12:10:18.713409+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T11:00:00+00:00 EmrJobFlowSensor 2021-05-05T12:01:06.332310+00:00 2021-05-05T12:10:09.195057+00:00 0:09:02.862747 24723 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T12:01:03.879214+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T12:00:43.869133+00:00 2021-05-05T12:00:45.599938+00:00 0:00:01.730805 24722 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T12:00:41.730351+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T11:00:00+00:00 PythonOperator 2021-05-05T12:00:22.403240+00:00 2021-05-05T12:00:25.513263+00:00 0:00:03.110023 24721 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T12:00:19.755249+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T10:00:00+00:00 TriggerDagRunOperator 2021-05-05T11:11:17.127169+00:00 2021-05-05T11:11:17.656902+00:00 0:00:00.529733 24713 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T11:11:14.796800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T10:00:00+00:00 TriggerDagRunOperator 2021-05-05T11:11:16.990589+00:00 2021-05-05T11:11:17.413122+00:00 0:00:00.422533 24712 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T11:11:14.796752+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T10:00:00+00:00 EmrJobFlowSensor 2021-05-05T11:00:50.148892+00:00 2021-05-05T11:10:53.165551+00:00 0:10:03.016659 24708 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T11:00:47.721896+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T11:00:28.139750+00:00 2021-05-05T11:00:29.846656+00:00 0:00:01.706906 24707 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T11:00:25.785508+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T10:00:00+00:00 PythonOperator 2021-05-05T11:00:08.167412+00:00 2021-05-05T11:00:11.310720+00:00 0:00:03.143308 24706 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T11:00:05.747616+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T09:00:00+00:00 TriggerDagRunOperator 2021-05-05T10:11:01.026380+00:00 2021-05-05T10:11:01.510106+00:00 0:00:00.483726 24698 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T10:10:58.652590+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T09:00:00+00:00 TriggerDagRunOperator 2021-05-05T10:11:01.025951+00:00 2021-05-05T10:11:01.592570+00:00 0:00:00.566619 24697 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T10:10:58.652553+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T09:00:00+00:00 EmrJobFlowSensor 2021-05-05T10:00:51.947335+00:00 2021-05-05T10:10:54.771638+00:00 0:10:02.824303 24693 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T10:00:49.699054+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T10:00:31.979321+00:00 2021-05-05T10:00:33.722112+00:00 0:00:01.742791 24692 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T10:00:29.756181+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T09:00:00+00:00 PythonOperator 2021-05-05T10:00:10.261878+00:00 2021-05-05T10:00:13.291940+00:00 0:00:03.030062 24691 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T10:00:07.619496+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T08:00:00+00:00 TriggerDagRunOperator 2021-05-05T09:11:34.137954+00:00 2021-05-05T09:11:34.709537+00:00 0:00:00.571583 24683 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T09:11:31.591971+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T08:00:00+00:00 TriggerDagRunOperator 2021-05-05T09:11:33.806450+00:00 2021-05-05T09:11:34.234684+00:00 0:00:00.428234 24682 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T09:11:31.591923+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T08:00:00+00:00 EmrJobFlowSensor 2021-05-05T09:01:04.974472+00:00 2021-05-05T09:11:07.932695+00:00 0:10:02.958223 24678 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T09:01:02.613548+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T09:00:42.928553+00:00 2021-05-05T09:00:44.627665+00:00 0:00:01.699112 24677 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T09:00:40.592515+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T08:00:00+00:00 PythonOperator 2021-05-05T09:00:23.139859+00:00 2021-05-05T09:00:26.183397+00:00 0:00:03.043538 24676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T09:00:20.519970+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T07:00:00+00:00 TriggerDagRunOperator 2021-05-05T08:11:05.866148+00:00 2021-05-05T08:11:06.420647+00:00 0:00:00.554499 24668 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T08:11:03.485005+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T07:00:00+00:00 TriggerDagRunOperator 2021-05-05T08:11:05.632219+00:00 2021-05-05T08:11:06.039432+00:00 0:00:00.407213 24667 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T08:11:03.484941+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T07:00:00+00:00 EmrJobFlowSensor 2021-05-05T08:00:48.580943+00:00 2021-05-05T08:10:51.465929+00:00 0:10:02.884986 24663 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T08:00:46.282552+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T08:00:28.862303+00:00 2021-05-05T08:00:30.717548+00:00 0:00:01.855245 24662 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T08:00:26.276773+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T07:00:00+00:00 PythonOperator 2021-05-05T08:00:06.674721+00:00 2021-05-05T08:00:09.706758+00:00 0:00:03.032037 24661 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T08:00:04.184125+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T06:00:00+00:00 TriggerDagRunOperator 2021-05-05T07:10:13.143730+00:00 2021-05-05T07:10:13.685037+00:00 0:00:00.541307 24653 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T07:10:10.794769+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T06:00:00+00:00 TriggerDagRunOperator 2021-05-05T07:10:12.988299+00:00 2021-05-05T07:10:13.426739+00:00 0:00:00.438440 24652 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T07:10:10.794803+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T06:00:00+00:00 EmrJobFlowSensor 2021-05-05T07:00:56.323290+00:00 2021-05-05T07:09:59.120757+00:00 0:09:02.797467 24648 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T07:00:53.848892+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T07:00:34.199547+00:00 2021-05-05T07:00:35.914322+00:00 0:00:01.714775 24647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T07:00:31.829553+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T06:00:00+00:00 PythonOperator 2021-05-05T07:00:12.337792+00:00 2021-05-05T07:00:15.391026+00:00 0:00:03.053234 24646 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T07:00:09.872204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T05:00:00+00:00 TriggerDagRunOperator 2021-05-05T06:10:37.801049+00:00 2021-05-05T06:10:38.333666+00:00 0:00:00.532617 24638 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T06:10:35.284057+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T05:00:00+00:00 TriggerDagRunOperator 2021-05-05T06:10:37.689804+00:00 2021-05-05T06:10:38.102696+00:00 0:00:00.412892 24637 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T06:10:35.284031+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T05:00:00+00:00 EmrJobFlowSensor 2021-05-05T06:00:58.419223+00:00 2021-05-05T06:10:01.178232+00:00 0:09:02.759009 24633 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T06:00:56.122980+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T06:00:36.456347+00:00 2021-05-05T06:00:38.269066+00:00 0:00:01.812719 24632 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T06:00:34.107117+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T05:00:00+00:00 PythonOperator 2021-05-05T06:00:14.796392+00:00 2021-05-05T06:00:17.841690+00:00 0:00:03.045298 24631 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T06:00:12.085336+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T04:00:00+00:00 TriggerDagRunOperator 2021-05-05T05:09:10.960749+00:00 2021-05-05T05:09:11.464885+00:00 0:00:00.504136 24623 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T05:09:08.575527+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T04:00:00+00:00 TriggerDagRunOperator 2021-05-05T05:09:10.911318+00:00 2021-05-05T05:09:11.493876+00:00 0:00:00.582558 24622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T05:09:08.575492+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T04:00:00+00:00 EmrJobFlowSensor 2021-05-05T05:00:58.038530+00:00 2021-05-05T05:09:00.613139+00:00 0:08:02.574609 24618 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T05:00:55.611257+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T05:00:36.061562+00:00 2021-05-05T05:00:37.893449+00:00 0:00:01.831887 24617 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T05:00:33.656865+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T04:00:00+00:00 PythonOperator 2021-05-05T05:00:14.000980+00:00 2021-05-05T05:00:17.067492+00:00 0:00:03.066512 24616 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T05:00:11.554949+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T03:00:00+00:00 TriggerDagRunOperator 2021-05-05T04:10:40.803577+00:00 2021-05-05T04:10:41.339220+00:00 0:00:00.535643 24608 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T04:10:38.453954+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T03:00:00+00:00 TriggerDagRunOperator 2021-05-05T04:10:40.764815+00:00 2021-05-05T04:10:41.186660+00:00 0:00:00.421845 24607 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T04:10:38.453996+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T03:00:00+00:00 EmrJobFlowSensor 2021-05-05T04:01:15.697685+00:00 2021-05-05T04:10:18.491335+00:00 0:09:02.793650 24603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T04:01:13.320215+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T04:00:49.432011+00:00 2021-05-05T04:00:51.105352+00:00 0:00:01.673341 24602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T04:00:47.296832+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T03:00:00+00:00 PythonOperator 2021-05-05T04:00:21.398148+00:00 2021-05-05T04:00:24.441309+00:00 0:00:03.043161 24601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T04:00:19.211344+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T02:00:00+00:00 TriggerDagRunOperator 2021-05-05T03:11:07.203352+00:00 2021-05-05T03:11:07.645289+00:00 0:00:00.441937 24593 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T03:11:04.612839+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T02:00:00+00:00 TriggerDagRunOperator 2021-05-05T03:11:06.995918+00:00 2021-05-05T03:11:07.527085+00:00 0:00:00.531167 24592 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T03:11:04.612809+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T02:00:00+00:00 EmrJobFlowSensor 2021-05-05T03:00:56.058873+00:00 2021-05-05T03:10:58.961594+00:00 0:10:02.902721 24588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T03:00:53.646488+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T03:00:33.808227+00:00 2021-05-05T03:00:35.518040+00:00 0:00:01.709813 24587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T03:00:31.583449+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T02:00:00+00:00 PythonOperator 2021-05-05T03:00:11.853389+00:00 2021-05-05T03:00:14.957248+00:00 0:00:03.103859 24586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T03:00:09.535280+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T01:00:00+00:00 TriggerDagRunOperator 2021-05-05T02:10:05.605321+00:00 2021-05-05T02:10:06.020496+00:00 0:00:00.415175 24578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T02:10:02.983122+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T01:00:00+00:00 TriggerDagRunOperator 2021-05-05T02:10:05.618302+00:00 2021-05-05T02:10:06.152423+00:00 0:00:00.534121 24577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T02:10:02.983172+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T01:00:00+00:00 EmrJobFlowSensor 2021-05-05T02:00:57.992000+00:00 2021-05-05T02:10:00.569974+00:00 0:09:02.577974 24573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T02:00:55.893826+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T02:00:38.116816+00:00 2021-05-05T02:00:39.934305+00:00 0:00:01.817489 24572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T02:00:35.808784+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T01:00:00+00:00 PythonOperator 2021-05-05T02:00:14.068179+00:00 2021-05-05T02:00:17.132323+00:00 0:00:03.064144 24571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T02:00:11.854443+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-05T00:00:00+00:00 TriggerDagRunOperator 2021-05-05T01:13:13.392912+00:00 2021-05-05T01:13:13.946363+00:00 0:00:00.553451 24564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T01:13:10.865998+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-05T00:00:00+00:00 TriggerDagRunOperator 2021-05-05T01:13:13.356475+00:00 2021-05-05T01:13:13.786556+00:00 0:00:00.430081 24563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T01:13:10.865970+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-05T00:00:00+00:00 EmrJobFlowSensor 2021-05-05T01:01:08.204123+00:00 2021-05-05T01:11:11.070900+00:00 0:10:02.866777 24558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T01:01:06.092451+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-05T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T01:00:44.413848+00:00 2021-05-05T01:00:46.128806+00:00 0:00:01.714958 24557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T01:00:42.153062+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-05T00:00:00+00:00 PythonOperator 2021-05-05T01:00:24.311180+00:00 2021-05-05T01:00:27.416661+00:00 0:00:03.105481 24556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T01:00:22.024508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T23:00:00+00:00 TriggerDagRunOperator 2021-05-05T00:09:32.827656+00:00 2021-05-05T00:09:33.260713+00:00 0:00:00.433057 24549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T00:09:30.343648+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T23:00:00+00:00 TriggerDagRunOperator 2021-05-05T00:09:32.858900+00:00 2021-05-05T00:09:33.447622+00:00 0:00:00.588722 24548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T00:09:30.343677+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T23:00:00+00:00 EmrJobFlowSensor 2021-05-05T00:01:05.704278+00:00 2021-05-05T00:09:08.383307+00:00 0:08:02.679029 24543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T00:01:03.346693+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T23:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T00:00:45.475892+00:00 2021-05-05T00:00:47.138895+00:00 0:00:01.663003 24542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-05T00:00:43.294958+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T23:00:00+00:00 PythonOperator 2021-05-05T00:00:23.849652+00:00 2021-05-05T00:00:26.949123+00:00 0:00:03.099471 24541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-05T00:00:21.187780+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T22:00:00+00:00 TriggerDagRunOperator 2021-05-04T23:09:24.501930+00:00 2021-05-04T23:09:25.013633+00:00 0:00:00.511703 24534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T23:09:22.184508+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T22:00:00+00:00 TriggerDagRunOperator 2021-05-04T23:09:24.455164+00:00 2021-05-04T23:09:24.841630+00:00 0:00:00.386466 24533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T23:09:22.184541+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T22:00:00+00:00 EmrJobFlowSensor 2021-05-04T23:01:08.615105+00:00 2021-05-04T23:09:11.327869+00:00 0:08:02.712764 24527 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T23:01:06.220018+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T22:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T23:00:40.650573+00:00 2021-05-04T23:00:42.453553+00:00 0:00:01.802980 24526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T23:00:38.244753+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T22:00:00+00:00 PythonOperator 2021-05-04T23:00:18.335027+00:00 2021-05-04T23:00:21.417995+00:00 0:00:03.082968 24523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T23:00:16.099574+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T21:00:00+00:00 TriggerDagRunOperator 2021-05-04T22:10:05.884047+00:00 2021-05-04T22:10:06.343716+00:00 0:00:00.459669 24516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T22:10:03.054277+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T21:00:00+00:00 TriggerDagRunOperator 2021-05-04T22:10:05.739048+00:00 2021-05-04T22:10:06.303440+00:00 0:00:00.564392 24515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T22:10:03.054326+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T21:00:00+00:00 EmrJobFlowSensor 2021-05-04T22:00:54.526152+00:00 2021-05-04T22:09:57.178286+00:00 0:09:02.652134 24510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T22:00:52.358009+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T21:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T22:00:34.631545+00:00 2021-05-04T22:00:36.453820+00:00 0:00:01.822275 24509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T22:00:32.342815+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T21:00:00+00:00 PythonOperator 2021-05-04T22:00:12.512708+00:00 2021-05-04T22:00:15.603725+00:00 0:00:03.091017 24508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T22:00:10.319293+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T20:00:00+00:00 TriggerDagRunOperator 2021-05-04T21:12:42.386984+00:00 2021-05-04T21:12:42.916425+00:00 0:00:00.529441 24501 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T21:12:40.004638+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T20:00:00+00:00 TriggerDagRunOperator 2021-05-04T21:12:42.209954+00:00 2021-05-04T21:12:42.743370+00:00 0:00:00.533416 24500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T21:12:40.004606+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T20:00:00+00:00 EmrJobFlowSensor 2021-05-04T21:02:17.333297+00:00 2021-05-04T21:12:20.197063+00:00 0:10:02.863766 24496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T21:02:15.032949+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T20:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T21:01:55.343657+00:00 2021-05-04T21:01:57.141276+00:00 0:00:01.797619 24495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T21:01:53.002588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T20:00:00+00:00 PythonOperator 2021-05-04T21:01:35.731842+00:00 2021-05-04T21:01:38.852310+00:00 0:00:03.120468 24494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T21:01:32.988373+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T19:00:00+00:00 TriggerDagRunOperator 2021-05-04T20:09:24.595295+00:00 2021-05-04T20:09:25.129577+00:00 0:00:00.534282 24486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T20:09:22.110629+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T19:00:00+00:00 TriggerDagRunOperator 2021-05-04T20:09:24.567098+00:00 2021-05-04T20:09:24.969716+00:00 0:00:00.402618 24485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T20:09:22.110598+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T19:00:00+00:00 EmrJobFlowSensor 2021-05-04T20:01:06.006267+00:00 2021-05-04T20:09:08.677048+00:00 0:08:02.670781 24481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T20:01:03.555374+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T20:00:43.781569+00:00 2021-05-04T20:00:45.595913+00:00 0:00:01.814344 24480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T20:00:41.488358+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T19:00:00+00:00 PythonOperator 2021-05-04T20:00:23.713331+00:00 2021-05-04T20:00:26.810540+00:00 0:00:03.097209 24479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T20:00:21.417223+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T18:00:00+00:00 TriggerDagRunOperator 2021-05-04T19:11:07.376595+00:00 2021-05-04T19:11:07.914293+00:00 0:00:00.537698 24471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T19:11:04.850812+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T18:00:00+00:00 TriggerDagRunOperator 2021-05-04T19:11:07.326158+00:00 2021-05-04T19:11:07.765417+00:00 0:00:00.439259 24470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T19:11:04.850763+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T18:00:00+00:00 EmrJobFlowSensor 2021-05-04T19:00:58.010843+00:00 2021-05-04T19:11:00.961313+00:00 0:10:02.950470 24466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T19:00:55.701265+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T19:00:36.000856+00:00 2021-05-04T19:00:37.728260+00:00 0:00:01.727404 24465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T19:00:33.646182+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-04T18:00:00+00:00 PythonOperator 2021-05-04T19:00:14.254956+00:00 2021-05-04T19:00:17.398564+00:00 0:00:03.143608 24464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-04T19:00:11.628068+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-04T17:00:00+00:00 TriggerDagRunOperator 2021-05-04T18:10:57.352321+00:00 2021-05-04T18:10:57.866621+00:00 0:00:00.514300 24456 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T18:10:54.458872+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-04T17:00:00+00:00 TriggerDagRunOperator 2021-05-04T18:10:56.921537+00:00 2021-05-04T18:10:57.375664+00:00 0:00:00.454127 24455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-04T18:10:54.458919+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-04T17:00:00+00:00 EmrJobFlowSensor 2021-05-04T18:00:47.504869+00:00 2021-05-04T18:10:50.364431+00:00 0:10:02.859562 24451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-04T18:00:45.162113+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-05-04T18:00:25.513551+00:00 2021-05-04T18:00:27.309917+00:00 0:00:01.796366 24450 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-04T18:00:23.085210+00:00 2 default_pool