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 campaign-history-job_v002 check_cluster_status 2021-04-13T03:00:00+00:00 EmrJobFlowSensor 2021-04-13T04:11:21.729038+00:00 2021-04-13T04:20:24.546245+00:00 0:09:02.817207 16603 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:11:19.498955+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:11:04.206823+00:00 2021-04-13T04:11:05.966185+00:00 0:00:01.759362 16602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T04:11:01.487875+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:11:01.621585+00:00 2021-04-13T04:11:03.715862+00:00 0:00:02.094277 16601 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T04:10:59.481649+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T03:00:00+00:00 PythonOperator 2021-04-13T04:10:42.374202+00:00 2021-04-13T04:10:45.324679+00:00 0:00:02.950477 16600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:10:39.460469+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T03:00:00+00:00 PythonOperator 2021-04-13T04:10:40.294648+00:00 2021-04-13T04:10:43.383274+00:00 0:00:03.088626 16599 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:10:37.457303+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T03:00:00+00:00 TriggerDagRunOperator 2021-04-13T04:10:24.331862+00:00 2021-04-13T04:10:24.898049+00:00 0:00:00.566187 16598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:10:21.487875+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T03:00:00+00:00 TriggerDagRunOperator 2021-04-13T04:10:23.872058+00:00 2021-04-13T04:10:24.417510+00:00 0:00:00.545452 16597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:10:21.487835+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T03:05:00+00:00 EmrJobFlowSensor 2021-04-13T04:06:03.228704+00:00 2021-04-13T04:15:05.992416+00:00 0:09:02.763712 16596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T04:06:00.884608+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T03:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:05:41.090515+00:00 2021-04-13T04:05:42.729018+00:00 0:00:01.638503 16595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T04:05:38.871388+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T03:05:00+00:00 PythonOperator 2021-04-13T04:05:19.025067+00:00 2021-04-13T04:05:21.687847+00:00 0:00:02.662780 16594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:05:16.800204+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T03:00:00+00:00 EmrJobFlowSensor 2021-04-13T04:01:01.135454+00:00 2021-04-13T04:10:04.006763+00:00 0:09:02.871309 16593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T04:00:58.641291+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T03:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T04:00:40.651965+00:00 2021-04-13T04:00:42.353699+00:00 0:00:01.701734 16592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T04:00:38.429945+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T03:00:00+00:00 PythonOperator 2021-04-13T04:00:19.387546+00:00 2021-04-13T04:00:22.233159+00:00 0:00:02.845613 16591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T04:00:16.472355+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T02:00:00+00:00 EmrJobFlowSensor 2021-04-13T03:11:29.396242+00:00 2021-04-13T03:21:32.218841+00:00 0:10:02.822599 16589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:11:26.840681+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T02:00:00+00:00 EmrJobFlowSensor 2021-04-13T03:11:23.191916+00:00 2021-04-13T03:20:26.072748+00:00 0:09:02.880832 16588 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:11:20.837876+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T03:11:07.235095+00:00 2021-04-13T03:11:08.998781+00:00 0:00:01.763686 16587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T03:11:04.867057+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T03:11:01.050338+00:00 2021-04-13T03:11:02.738121+00:00 0:00:01.687783 16586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T03:10:58.843858+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T02:00:00+00:00 PythonOperator 2021-04-13T03:10:47.210868+00:00 2021-04-13T03:10:50.313618+00:00 0:00:03.102750 16585 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T03:10:44.855528+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T02:00:00+00:00 PythonOperator 2021-04-13T03:10:39.127391+00:00 2021-04-13T03:10:41.893249+00:00 0:00:02.765858 16584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T03:10:36.806431+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T02:00:00+00:00 TriggerDagRunOperator 2021-04-13T03:10:21.751954+00:00 2021-04-13T03:10:22.263757+00:00 0:00:00.511803 16583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:10:18.797270+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T02:00:00+00:00 TriggerDagRunOperator 2021-04-13T03:10:21.191713+00:00 2021-04-13T03:10:21.611076+00:00 0:00:00.419363 16582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:10:18.797217+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T02:05:00+00:00 EmrJobFlowSensor 2021-04-13T03:06:02.568614+00:00 2021-04-13T03:15:05.213580+00:00 0:09:02.644966 16581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T03:06:00.359638+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T02:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T03:05:40.401017+00:00 2021-04-13T03:05:42.490844+00:00 0:00:02.089827 16580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T03:05:38.270748+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T02:05:00+00:00 PythonOperator 2021-04-13T03:05:18.669133+00:00 2021-04-13T03:05:21.433075+00:00 0:00:02.763942 16579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T03:05:16.225854+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T02:00:00+00:00 EmrJobFlowSensor 2021-04-13T03:00:54.103114+00:00 2021-04-13T03:09:56.890310+00:00 0:09:02.787196 16578 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T03:00:51.730627+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T02:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T03:00:32.215650+00:00 2021-04-13T03:00:33.960083+00:00 0:00:01.744433 16577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T03:00:29.772432+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T02:00:00+00:00 PythonOperator 2021-04-13T03:00:10.028554+00:00 2021-04-13T03:00:12.928620+00:00 0:00:02.900066 16576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T03:00:07.689112+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T01:00:00+00:00 EmrJobFlowSensor 2021-04-13T02:21:45.939271+00:00 2021-04-13T02:31:48.776243+00:00 0:10:02.836972 16575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:21:43.546541+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T01:00:00+00:00 EmrJobFlowSensor 2021-04-13T02:21:41.673025+00:00 2021-04-13T02:38:45.435862+00:00 0:17:03.762837 16574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:21:39.489316+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T02:21:26.106089+00:00 2021-04-13T02:21:27.792101+00:00 0:00:01.686012 16573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T02:21:23.411872+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T02:21:19.842850+00:00 2021-04-13T02:21:21.643428+00:00 0:00:01.800578 16572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T02:21:17.409344+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T01:00:00+00:00 PythonOperator 2021-04-13T02:21:03.681664+00:00 2021-04-13T02:21:06.627575+00:00 0:00:02.945911 16571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T02:21:01.385011+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T01:00:00+00:00 PythonOperator 2021-04-13T02:20:59.782098+00:00 2021-04-13T02:21:02.671515+00:00 0:00:02.889417 16570 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T02:20:57.391822+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T01:00:00+00:00 TriggerDagRunOperator 2021-04-13T02:20:43.894400+00:00 2021-04-13T02:20:44.362854+00:00 0:00:00.468454 16569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:20:41.320839+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T01:00:00+00:00 TriggerDagRunOperator 2021-04-13T02:20:43.814956+00:00 2021-04-13T02:20:44.377999+00:00 0:00:00.563043 16568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:20:41.320868+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T01:05:00+00:00 EmrJobFlowSensor 2021-04-13T02:05:56.451432+00:00 2021-04-13T02:14:59.084846+00:00 0:09:02.633414 16566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T02:05:53.977885+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T01:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T02:05:36.298462+00:00 2021-04-13T02:05:38.266510+00:00 0:00:01.968048 16565 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T02:05:33.961855+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T01:05:00+00:00 PythonOperator 2021-04-13T02:05:13.990676+00:00 2021-04-13T02:05:16.691105+00:00 0:00:02.700429 16564 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T02:05:11.846743+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T01:00:00+00:00 EmrJobFlowSensor 2021-04-13T02:00:53.645445+00:00 2021-04-13T02:08:56.237354+00:00 0:08:02.591909 16563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T02:00:51.435659+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T01:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T02:00:33.789604+00:00 2021-04-13T02:00:35.656030+00:00 0:00:01.866426 16562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T02:00:31.415370+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T01:00:00+00:00 PythonOperator 2021-04-13T02:00:09.993309+00:00 2021-04-13T02:00:12.778363+00:00 0:00:02.785054 16561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T02:00:07.450542+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-13T00:00:00+00:00 EmrJobFlowSensor 2021-04-13T01:11:15.005704+00:00 2021-04-13T01:20:17.690535+00:00 0:09:02.684831 16560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:11:12.752447+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-13T00:00:00+00:00 EmrJobFlowSensor 2021-04-13T01:11:06.971789+00:00 2021-04-13T01:20:09.789085+00:00 0:09:02.817296 16559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:11:04.742743+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-13T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T01:10:53.187754+00:00 2021-04-13T01:10:55.051712+00:00 0:00:01.863958 16558 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T01:10:50.729643+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-13T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T01:10:45.565638+00:00 2021-04-13T01:10:47.554479+00:00 0:00:01.988841 16557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T01:10:42.785244+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-13T00:00:00+00:00 PythonOperator 2021-04-13T01:10:31.210938+00:00 2021-04-13T01:10:34.724875+00:00 0:00:03.513937 16556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:10:28.777133+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-13T00:00:00+00:00 PythonOperator 2021-04-13T01:10:22.956203+00:00 2021-04-13T01:10:25.721923+00:00 0:00:02.765720 16555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:10:20.745427+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-13T00:00:00+00:00 TriggerDagRunOperator 2021-04-13T01:10:17.317853+00:00 2021-04-13T01:10:18.458169+00:00 0:00:01.140316 16554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:10:14.699694+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-13T00:00:00+00:00 TriggerDagRunOperator 2021-04-13T01:10:17.113438+00:00 2021-04-13T01:10:18.171106+00:00 0:00:01.057668 16553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:10:14.699722+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-13T00:05:00+00:00 EmrJobFlowSensor 2021-04-13T01:05:54.977306+00:00 2021-04-13T01:14:57.583633+00:00 0:09:02.606327 16551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T01:05:52.708545+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-13T00:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T01:05:33.307842+00:00 2021-04-13T01:05:35.029976+00:00 0:00:01.722134 16550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T01:05:30.754804+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-13T00:05:00+00:00 PythonOperator 2021-04-13T01:05:10.987995+00:00 2021-04-13T01:05:13.790052+00:00 0:00:02.802057 16549 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:05:08.741230+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-13T00:00:00+00:00 EmrJobFlowSensor 2021-04-13T01:01:03.034712+00:00 2021-04-13T01:10:05.782206+00:00 0:09:02.747494 16548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T01:01:00.213823+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-13T00:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T01:00:42.379934+00:00 2021-04-13T01:00:44.106005+00:00 0:00:01.726071 16547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T01:00:40.190815+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-13T00:00:00+00:00 PythonOperator 2021-04-13T01:00:16.330269+00:00 2021-04-13T01:00:19.051019+00:00 0:00:02.720750 16546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T01:00:14.150949+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T23:00:00+00:00 EmrJobFlowSensor 2021-04-13T00:12:27.197405+00:00 2021-04-13T00:22:29.932805+00:00 0:10:02.735400 16545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T00:12:24.955320+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T23:00:00+00:00 EmrJobFlowSensor 2021-04-13T00:12:11.330383+00:00 2021-04-13T00:22:14.348348+00:00 0:10:03.017965 16544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T00:12:08.940483+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T00:12:05.101674+00:00 2021-04-13T00:12:06.793240+00:00 0:00:01.691566 16543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T00:12:02.940168+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T00:11:49.467887+00:00 2021-04-13T00:11:51.302924+00:00 0:00:01.835037 16542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T00:11:46.939394+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T23:00:00+00:00 PythonOperator 2021-04-13T00:11:45.304040+00:00 2021-04-13T00:11:48.738447+00:00 0:00:03.434407 16541 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T00:11:42.918140+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T23:00:00+00:00 PythonOperator 2021-04-13T00:11:27.594594+00:00 2021-04-13T00:11:30.390148+00:00 0:00:02.795554 16540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T00:11:24.902328+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T23:00:00+00:00 TriggerDagRunOperator 2021-04-13T00:11:19.297540+00:00 2021-04-13T00:11:19.792964+00:00 0:00:00.495424 16539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T00:11:16.898923+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T23:00:00+00:00 TriggerDagRunOperator 2021-04-13T00:11:19.130349+00:00 2021-04-13T00:11:19.564659+00:00 0:00:00.434310 16538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T00:11:16.898885+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T23:05:00+00:00 EmrJobFlowSensor 2021-04-13T00:08:24.862171+00:00 2021-04-13T00:17:27.418421+00:00 0:09:02.556250 16537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-13T00:08:22.585632+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T23:05:00+00:00 EmrCreateJobFlowOperator 2021-04-13T00:07:54.665023+00:00 2021-04-13T00:07:56.283343+00:00 0:00:01.618320 16536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-13T00:07:52.511621+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T23:05:00+00:00 PythonOperator 2021-04-13T00:07:32.824761+00:00 2021-04-13T00:07:35.583697+00:00 0:00:02.758936 16535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T00:07:30.492652+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T23:00:00+00:00 EmrJobFlowSensor 2021-04-13T00:00:53.538477+00:00 2021-04-13T00:10:56.327010+00:00 0:10:02.788533 16533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-13T00:00:51.290186+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T23:00:00+00:00 EmrCreateJobFlowOperator 2021-04-13T00:00:33.565455+00:00 2021-04-13T00:00:35.249092+00:00 0:00:01.683637 16532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-13T00:00:31.246452+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T23:00:00+00:00 PythonOperator 2021-04-13T00:00:11.542797+00:00 2021-04-13T00:00:14.377818+00:00 0:00:02.835021 16531 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-13T00:00:09.190385+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T22:00:00+00:00 EmrJobFlowSensor 2021-04-12T23:12:05.099299+00:00 2021-04-12T23:22:07.881859+00:00 0:10:02.782560 16530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T23:12:02.745520+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T22:00:00+00:00 EmrJobFlowSensor 2021-04-12T23:11:46.916660+00:00 2021-04-12T23:21:49.695693+00:00 0:10:02.779033 16529 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T23:11:44.606752+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T23:11:38.803083+00:00 2021-04-12T23:11:40.477416+00:00 0:00:01.674333 16528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T23:11:36.603973+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T23:11:22.803882+00:00 2021-04-12T23:11:24.543785+00:00 0:00:01.739903 16527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T23:11:20.585655+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T22:00:00+00:00 PythonOperator 2021-04-12T23:11:16.904415+00:00 2021-04-12T23:11:19.965356+00:00 0:00:03.060941 16526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T23:11:14.587104+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T22:00:00+00:00 PythonOperator 2021-04-12T23:11:00.941591+00:00 2021-04-12T23:11:03.760784+00:00 0:00:02.819193 16525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T23:10:58.582204+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T22:00:00+00:00 TriggerDagRunOperator 2021-04-12T23:10:55.815081+00:00 2021-04-12T23:10:56.339168+00:00 0:00:00.524087 16524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T23:10:52.575035+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T22:00:00+00:00 TriggerDagRunOperator 2021-04-12T23:10:55.710233+00:00 2021-04-12T23:10:56.114415+00:00 0:00:00.404182 16523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T23:10:52.575087+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T22:05:00+00:00 EmrJobFlowSensor 2021-04-12T23:05:58.195008+00:00 2021-04-12T23:14:00.619333+00:00 0:08:02.424325 16522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T23:05:56.055171+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T22:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T23:05:38.194826+00:00 2021-04-12T23:05:39.938569+00:00 0:00:01.743743 16521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T23:05:35.937834+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T22:05:00+00:00 PythonOperator 2021-04-12T23:05:16.336419+00:00 2021-04-12T23:05:19.321395+00:00 0:00:02.984976 16520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T23:05:13.976573+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T22:00:00+00:00 EmrJobFlowSensor 2021-04-12T23:01:45.911044+00:00 2021-04-12T23:10:48.547291+00:00 0:09:02.636247 16519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T23:01:43.675513+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T22:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T23:01:26.176746+00:00 2021-04-12T23:01:27.890454+00:00 0:00:01.713708 16518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T23:01:23.649140+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T22:00:00+00:00 PythonOperator 2021-04-12T23:01:04.097390+00:00 2021-04-12T23:01:06.856516+00:00 0:00:02.759126 16517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T23:01:01.577311+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T21:00:00+00:00 EmrJobFlowSensor 2021-04-12T22:10:04.184998+00:00 2021-04-12T22:20:06.954915+00:00 0:10:02.769917 16515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:10:02.027840+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T21:00:00+00:00 EmrJobFlowSensor 2021-04-12T22:09:48.489208+00:00 2021-04-12T22:19:51.185015+00:00 0:10:02.695807 16514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:09:46.050313+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-12T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T22:09:42.422153+00:00 2021-04-12T22:09:44.269850+00:00 0:00:01.847697 16513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T22:09:40.056134+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T22:09:26.401480+00:00 2021-04-12T22:09:28.085083+00:00 0:00:01.683603 16512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T22:09:24.046234+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-12T21:00:00+00:00 PythonOperator 2021-04-12T22:09:22.328331+00:00 2021-04-12T22:09:25.403141+00:00 0:00:03.074810 16511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:09:19.985931+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-12T21:00:00+00:00 PythonOperator 2021-04-12T22:09:06.232118+00:00 2021-04-12T22:09:09.141234+00:00 0:00:02.909116 16510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:09:03.891404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-12T21:00:00+00:00 TriggerDagRunOperator 2021-04-12T22:09:00.750747+00:00 2021-04-12T22:09:01.156860+00:00 0:00:00.406113 16509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:08:57.956906+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-12T21:00:00+00:00 TriggerDagRunOperator 2021-04-12T22:09:00.537255+00:00 2021-04-12T22:09:01.085051+00:00 0:00:00.547796 16508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:08:57.956874+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-12T21:05:00+00:00 EmrJobFlowSensor 2021-04-12T22:05:51.807427+00:00 2021-04-12T22:14:54.468575+00:00 0:09:02.661148 16507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T22:05:49.679066+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-12T21:05:00+00:00 EmrCreateJobFlowOperator 2021-04-12T22:05:28.002313+00:00 2021-04-12T22:05:29.632210+00:00 0:00:01.629897 16506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T22:05:25.669069+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-12T21:05:00+00:00 PythonOperator 2021-04-12T22:05:08.084915+00:00 2021-04-12T22:05:10.753289+00:00 0:00:02.668374 16505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:05:05.644638+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-12T21:00:00+00:00 EmrJobFlowSensor 2021-04-12T22:00:51.392173+00:00 2021-04-12T22:08:53.937850+00:00 0:08:02.545677 16504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-12T22:00:49.089689+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-12T21:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T22:00:29.563004+00:00 2021-04-12T22:00:31.236769+00:00 0:00:01.673765 16503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-12T22:00:27.063621+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-12T21:00:00+00:00 PythonOperator 2021-04-12T22:00:07.635171+00:00 2021-04-12T22:00:10.357472+00:00 0:00:02.722301 16502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-12T22:00:05.052891+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-12T20:00:00+00:00 EmrJobFlowSensor 2021-04-12T21:23:56.731778+00:00 2021-04-12T21:23:58.211610+00:00 0:00:01.479832 16500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:23:54.476141+00:00 3 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-12T20:00:00+00:00 EmrJobFlowSensor 2021-04-12T21:11:21.730181+00:00 2021-04-12T21:20:24.421133+00:00 0:09:02.690952 16498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-12T21:11:19.425036+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-12T20:00:00+00:00 EmrCreateJobFlowOperator 2021-04-12T21:11:11.608100+00:00 2021-04-12T21:11:13.392344+00:00 0:00:01.784244 16497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-12T21:11:09.414255+00:00 2 default_pool