Task Instances

  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 vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T08:05:27.334243+00:00 2021-05-05T08:05:29.089391+00:00 0:00:01.755148 24665 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T08:05:24.943950+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T07:05:00+00:00 PythonOperator 2021-05-05T08:05:06.981505+00:00 2021-05-05T08:05:10.023961+00:00 0:00:03.042456 24664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T08:05:04.787488+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-history-job_v002 check_cluster_status 2021-05-05T06:00:00+00:00 EmrJobFlowSensor 2021-05-05T07:11:15.126685+00:00 2021-05-05T07:20:17.694581+00:00 0:09:02.567896 24659 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T07:11:12.914013+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T06:00:00+00:00 EmrJobFlowSensor 2021-05-05T07:11:03.825345+00:00 2021-05-05T07:20:06.650882+00:00 0:09:02.825537 24658 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T07:11:00.904671+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T07:10:55.332142+00:00 2021-05-05T07:10:57.113830+00:00 0:00:01.781688 24657 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T07:10:52.895033+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T07:10:41.725076+00:00 2021-05-05T07:10:43.511287+00:00 0:00:01.786211 24656 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T07:10:38.949930+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T06:00:00+00:00 PythonOperator 2021-05-05T07:10:33.372594+00:00 2021-05-05T07:10:36.422505+00:00 0:00:03.049911 24655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T07:10:30.874365+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T06:00:00+00:00 PythonOperator 2021-05-05T07:10:21.480385+00:00 2021-05-05T07:10:24.732285+00:00 0:00:03.251900 24654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T07:10:18.856302+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 vc-asset-import_v002 check_cluster_status 2021-05-05T06:05:00+00:00 EmrJobFlowSensor 2021-05-05T07:06:14.704249+00:00 2021-05-05T07:14:17.301789+00:00 0:08:02.597540 24651 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T07:06:12.454714+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T07:05:48.442685+00:00 2021-05-05T07:05:50.103186+00:00 0:00:01.660501 24650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T07:05:46.322164+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T06:05:00+00:00 PythonOperator 2021-05-05T07:05:20.372028+00:00 2021-05-05T07:05:23.386850+00:00 0:00:03.014822 24649 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T07:05:18.291985+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-history-job_v002 check_cluster_status 2021-05-05T05:00:00+00:00 EmrJobFlowSensor 2021-05-05T06:11:43.731622+00:00 2021-05-05T06:19:46.350945+00:00 0:08:02.619323 24644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T06:11:41.338857+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T05:00:00+00:00 EmrJobFlowSensor 2021-05-05T06:11:27.710773+00:00 2021-05-05T06:25:31.055548+00:00 0:14:03.344775 24643 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T06:11:25.326202+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T06:11:23.548542+00:00 2021-05-05T06:11:25.258972+00:00 0:00:01.710430 24642 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T06:11:21.321376+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T05:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T06:11:05.755775+00:00 2021-05-05T06:11:07.561114+00:00 0:00:01.805339 24641 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T06:11:03.369295+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T05:00:00+00:00 PythonOperator 2021-05-05T06:11:01.513999+00:00 2021-05-05T06:11:04.552572+00:00 0:00:03.038573 24640 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T06:10:59.309937+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T05:00:00+00:00 PythonOperator 2021-05-05T06:10:43.608051+00:00 2021-05-05T06:10:47.071611+00:00 0:00:03.463560 24639 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T06:10:41.288426+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 vc-asset-import_v002 check_cluster_status 2021-05-05T05:05:00+00:00 EmrJobFlowSensor 2021-05-05T06:05:48.995753+00:00 2021-05-05T06:13:51.542791+00:00 0:08:02.547038 24636 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T06:05:46.797972+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T05:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T06:05:26.863714+00:00 2021-05-05T06:05:28.526233+00:00 0:00:01.662519 24635 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T06:05:24.743470+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T05:05:00+00:00 PythonOperator 2021-05-05T06:05:05.040011+00:00 2021-05-05T06:05:08.136289+00:00 0:00:03.096278 24634 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T06:05:02.756113+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-history-job_v002 check_cluster_status 2021-05-05T04:00:00+00:00 EmrJobFlowSensor 2021-05-05T05:10:14.872773+00:00 2021-05-05T05:20:17.688644+00:00 0:10:02.815871 24629 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T05:10:12.631207+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T04:00:00+00:00 EmrJobFlowSensor 2021-05-05T05:10:10.836509+00:00 2021-05-05T05:20:13.617881+00:00 0:10:02.781372 24628 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T05:10:08.628470+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T05:09:54.847995+00:00 2021-05-05T05:09:56.655192+00:00 0:00:01.807197 24627 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T05:09:52.604154+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T04:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T05:09:50.789216+00:00 2021-05-05T05:09:52.514318+00:00 0:00:01.725102 24626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T05:09:48.601451+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T04:00:00+00:00 PythonOperator 2021-05-05T05:09:33.016581+00:00 2021-05-05T05:09:36.066313+00:00 0:00:03.049732 24625 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T05:09:30.653501+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T04:00:00+00:00 PythonOperator 2021-05-05T05:09:28.846771+00:00 2021-05-05T05:09:32.157311+00:00 0:00:03.310540 24624 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T05:09:26.546049+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 vc-asset-import_v002 check_cluster_status 2021-05-05T04:05:00+00:00 EmrJobFlowSensor 2021-05-05T05:05:50.369319+00:00 2021-05-05T05:14:52.939914+00:00 0:09:02.570595 24621 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T05:05:48.223960+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T04:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T05:05:28.634612+00:00 2021-05-05T05:05:30.287307+00:00 0:00:01.652695 24620 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T05:05:26.265493+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T04:05:00+00:00 PythonOperator 2021-05-05T05:05:06.520707+00:00 2021-05-05T05:05:09.499431+00:00 0:00:02.978724 24619 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T05:05:04.252336+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-history-job_v002 check_cluster_status 2021-05-05T03:00:00+00:00 EmrJobFlowSensor 2021-05-05T04:11:42.713257+00:00 2021-05-05T04:19:45.209794+00:00 0:08:02.496537 24614 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T04:11:40.494470+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T03:00:00+00:00 EmrJobFlowSensor 2021-05-05T04:11:32.617952+00:00 2021-05-05T04:20:35.163434+00:00 0:09:02.545482 24613 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T04:11:30.484110+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T04:11:20.622609+00:00 2021-05-05T04:11:22.318126+00:00 0:00:01.695517 24612 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T04:11:18.417850+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T03:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T04:11:10.943255+00:00 2021-05-05T04:11:12.725625+00:00 0:00:01.782370 24611 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T04:11:08.414925+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T03:00:00+00:00 PythonOperator 2021-05-05T04:10:59.033785+00:00 2021-05-05T04:11:02.090557+00:00 0:00:03.056772 24610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T04:10:56.461740+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T03:00:00+00:00 PythonOperator 2021-05-05T04:10:49.322932+00:00 2021-05-05T04:10:52.607920+00:00 0:00:03.284988 24609 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T04:10:46.462767+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 vc-asset-import_v002 check_cluster_status 2021-05-05T03:05:00+00:00 EmrJobFlowSensor 2021-05-05T04:05:56.045098+00:00 2021-05-05T04:14:58.727813+00:00 0:09:02.682715 24606 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T04:05:53.859028+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T03:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T04:05:34.353836+00:00 2021-05-05T04:05:36.008626+00:00 0:00:01.654790 24605 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T04:05:31.835529+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T03:05:00+00:00 PythonOperator 2021-05-05T04:05:12.190862+00:00 2021-05-05T04:05:15.200700+00:00 0:00:03.009838 24604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T04:05:09.871755+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 booking-processing-job_v002 check_cluster_status 2021-05-05T02:00:00+00:00 EmrJobFlowSensor 2021-05-05T03:12:23.276499+00:00 2021-05-05T03:21:25.925378+00:00 0:09:02.648879 24599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T03:12:20.845092+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T02:00:00+00:00 EmrJobFlowSensor 2021-05-05T03:12:02.976494+00:00 2021-05-05T03:20:05.568398+00:00 0:08:02.591904 24598 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T03:12:00.710260+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T03:11:48.893261+00:00 2021-05-05T03:11:50.576411+00:00 0:00:01.683150 24597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T03:11:46.700565+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T02:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T03:11:34.901275+00:00 2021-05-05T03:11:36.569746+00:00 0:00:01.668471 24596 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T03:11:32.686330+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T02:00:00+00:00 PythonOperator 2021-05-05T03:11:26.865032+00:00 2021-05-05T03:11:30.159805+00:00 0:00:03.294773 24595 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T03:11:24.629773+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T02:00:00+00:00 PythonOperator 2021-05-05T03:11:12.989965+00:00 2021-05-05T03:11:16.069176+00:00 0:00:03.079211 24594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T03:11:10.616750+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 vc-asset-import_v002 check_cluster_status 2021-05-05T02:05:00+00:00 EmrJobFlowSensor 2021-05-05T03:05:50.280704+00:00 2021-05-05T03:14:52.904433+00:00 0:09:02.623729 24591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T03:05:48.108489+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T02:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T03:05:30.498939+00:00 2021-05-05T03:05:32.160471+00:00 0:00:01.661532 24590 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T03:05:28.090499+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T02:05:00+00:00 PythonOperator 2021-05-05T03:05:08.443267+00:00 2021-05-05T03:05:11.425550+00:00 0:00:02.982283 24589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T03:05:06.089124+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 booking-processing-job_v002 check_cluster_status 2021-05-05T01:00:00+00:00 EmrJobFlowSensor 2021-05-05T02:11:01.392247+00:00 2021-05-05T02:21:04.231233+00:00 0:10:02.838986 24584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T02:10:59.161487+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-05T01:00:00+00:00 EmrJobFlowSensor 2021-05-05T02:10:55.298567+00:00 2021-05-05T02:20:58.117137+00:00 0:10:02.818570 24583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T02:10:53.045233+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T02:10:39.371005+00:00 2021-05-05T02:10:41.075212+00:00 0:00:01.704207 24582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T02:10:37.057359+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T01:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T02:10:33.291000+00:00 2021-05-05T02:10:34.971290+00:00 0:00:01.680290 24581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T02:10:31.040629+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T01:00:00+00:00 PythonOperator 2021-05-05T02:10:17.186056+00:00 2021-05-05T02:10:20.426152+00:00 0:00:03.240096 24580 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T02:10:14.989230+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T01:00:00+00:00 PythonOperator 2021-05-05T02:10:11.161041+00:00 2021-05-05T02:10:14.331238+00:00 0:00:03.170197 24579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T02:10:08.984811+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 vc-asset-import_v002 check_cluster_status 2021-05-05T01:05:00+00:00 EmrJobFlowSensor 2021-05-05T02:06:06.554537+00:00 2021-05-05T02:15:09.176988+00:00 0:09:02.622451 24576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T02:06:04.421170+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T01:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T02:05:46.592506+00:00 2021-05-05T02:05:48.359023+00:00 0:00:01.766517 24575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T02:05:44.404550+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T01:05:00+00:00 PythonOperator 2021-05-05T02:05:24.653030+00:00 2021-05-05T02:05:27.683861+00:00 0:00:03.030831 24574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T02:05:22.368532+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-history-job_v002 check_cluster_status 2021-05-05T00:00:00+00:00 EmrJobFlowSensor 2021-05-05T01:14:15.567382+00:00 2021-05-05T01:23:18.315710+00:00 0:09:02.748328 24570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T01:14:13.057201+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-05T00:00:00+00:00 EmrJobFlowSensor 2021-05-05T01:14:11.291667+00:00 2021-05-05T01:23:13.988900+00:00 0:09:02.697233 24569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T01:14:09.051581+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-05T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T01:13:53.055845+00:00 2021-05-05T01:13:54.723784+00:00 0:00:01.667939 24568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T01:13:50.936861+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-05T00:00:00+00:00 EmrCreateJobFlowOperator 2021-05-05T01:13:49.194575+00:00 2021-05-05T01:13:51.065218+00:00 0:00:01.870643 24567 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T01:13:46.951045+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-05T00:00:00+00:00 PythonOperator 2021-05-05T01:13:34.076020+00:00 2021-05-05T01:13:37.256821+00:00 0:00:03.180801 24566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T01:13:30.924104+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-05T00:00:00+00:00 PythonOperator 2021-05-05T01:13:29.053448+00:00 2021-05-05T01:13:33.039298+00:00 0:00:03.985850 24565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T01:13:26.879258+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 vc-asset-import_v002 check_cluster_status 2021-05-05T00:05:00+00:00 EmrJobFlowSensor 2021-05-05T01:05:58.777844+00:00 2021-05-05T01:15:01.383064+00:00 0:09:02.605220 24561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-05T01:05:56.558526+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-05T00:05:00+00:00 EmrCreateJobFlowOperator 2021-05-05T01:05:39.053116+00:00 2021-05-05T01:05:40.792808+00:00 0:00:01.739692 24560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-05T01:05:36.489080+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-05T00:05:00+00:00 PythonOperator 2021-05-05T01:05:16.687184+00:00 2021-05-05T01:05:19.679449+00:00 0:00:02.992265 24559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-05T01:05:14.440838+00:00 2 default_pool