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-04T19:00:00+00:00 EmrJobFlowSensor 2021-04-04T20:11:21.835292+00:00 2021-04-04T20:29:25.843278+00:00 0:18:04.007986 13601 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:11:19.601482+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T20:11:05.836561+00:00 2021-04-04T20:11:07.551676+00:00 0:00:01.715115 13600 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T20:11:03.587594+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T20:11:00.115971+00:00 2021-04-04T20:11:02.026379+00:00 0:00:01.910408 13599 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T20:10:57.585422+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T19:00:00+00:00 PythonOperator 2021-04-04T20:10:45.809530+00:00 2021-04-04T20:10:48.840749+00:00 0:00:03.031219 13598 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T20:10:43.524750+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T19:00:00+00:00 PythonOperator 2021-04-04T20:10:39.804390+00:00 2021-04-04T20:10:42.603364+00:00 0:00:02.798974 13597 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T20:10:37.527796+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T19:00:00+00:00 TriggerDagRunOperator 2021-04-04T20:10:20.022393+00:00 2021-04-04T20:10:20.550485+00:00 0:00:00.528092 13596 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:10:17.515097+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T19:00:00+00:00 TriggerDagRunOperator 2021-04-04T20:10:19.805993+00:00 2021-04-04T20:10:20.227071+00:00 0:00:00.421078 13595 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:10:17.515145+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T19:05:00+00:00 EmrJobFlowSensor 2021-04-04T20:05:57.616966+00:00 2021-04-04T20:15:00.202660+00:00 0:09:02.585694 13594 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T20:05:55.152036+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T19:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T20:05:35.618496+00:00 2021-04-04T20:05:37.355856+00:00 0:00:01.737360 13593 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T20:05:33.083132+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T19:05:00+00:00 PythonOperator 2021-04-04T20:05:15.179397+00:00 2021-04-04T20:05:17.863037+00:00 0:00:02.683640 13592 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T20:05:12.960309+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T19:00:00+00:00 EmrJobFlowSensor 2021-04-04T20:00:56.888559+00:00 2021-04-04T20:09:59.656788+00:00 0:09:02.768229 13591 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T20:00:54.586874+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T19:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T20:00:36.790320+00:00 2021-04-04T20:00:38.586483+00:00 0:00:01.796163 13590 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T20:00:34.547146+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T19:00:00+00:00 PythonOperator 2021-04-04T20:00:06.971057+00:00 2021-04-04T20:00:09.835452+00:00 0:00:02.864395 13589 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T20:00:04.489758+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T18:00:00+00:00 EmrJobFlowSensor 2021-04-04T19:09:54.368984+00:00 2021-04-04T19:19:57.149692+00:00 0:10:02.780708 13587 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:09:52.012812+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T18:00:00+00:00 EmrJobFlowSensor 2021-04-04T19:09:48.545111+00:00 2021-04-04T19:19:51.297806+00:00 0:10:02.752695 13586 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:09:46.048601+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T19:09:32.447556+00:00 2021-04-04T19:09:34.128886+00:00 0:00:01.681330 13585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T19:09:30.057941+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T19:09:28.225478+00:00 2021-04-04T19:09:29.913173+00:00 0:00:01.687695 13584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T19:09:25.989161+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T18:00:00+00:00 PythonOperator 2021-04-04T19:09:10.402385+00:00 2021-04-04T19:09:13.120295+00:00 0:00:02.717910 13583 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T19:09:07.976819+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T18:00:00+00:00 PythonOperator 2021-04-04T19:09:06.199840+00:00 2021-04-04T19:09:09.501755+00:00 0:00:03.301915 13582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T19:09:03.970494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T18:00:00+00:00 TriggerDagRunOperator 2021-04-04T19:08:56.381784+00:00 2021-04-04T19:08:56.903701+00:00 0:00:00.521917 13581 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:08:53.966252+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T18:00:00+00:00 TriggerDagRunOperator 2021-04-04T19:08:56.216814+00:00 2021-04-04T19:08:56.643556+00:00 0:00:00.426742 13580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:08:53.966219+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T18:05:00+00:00 EmrJobFlowSensor 2021-04-04T19:05:54.204551+00:00 2021-04-04T19:14:56.793458+00:00 0:09:02.588907 13579 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T19:05:51.759784+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T18:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T19:05:33.880078+00:00 2021-04-04T19:05:35.544899+00:00 0:00:01.664821 13578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T19:05:31.687851+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T18:05:00+00:00 PythonOperator 2021-04-04T19:05:11.991466+00:00 2021-04-04T19:05:14.661719+00:00 0:00:02.670253 13577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T19:05:09.610739+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T18:00:00+00:00 EmrJobFlowSensor 2021-04-04T19:00:47.419733+00:00 2021-04-04T19:08:50.061966+00:00 0:08:02.642233 13576 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T19:00:45.096458+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T18:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T19:00:25.566148+00:00 2021-04-04T19:00:27.369632+00:00 0:00:01.803484 13575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T19:00:23.078742+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T18:00:00+00:00 PythonOperator 2021-04-04T19:00:05.660743+00:00 2021-04-04T19:00:08.542141+00:00 0:00:02.881398 13574 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T19:00:03.068260+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T17:00:00+00:00 EmrJobFlowSensor 2021-04-04T18:11:26.106914+00:00 2021-04-04T18:21:28.826147+00:00 0:10:02.719233 13572 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:11:23.672600+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T17:00:00+00:00 EmrJobFlowSensor 2021-04-04T18:11:10.063485+00:00 2021-04-04T18:30:14.190769+00:00 0:19:04.127284 13571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:11:07.550128+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T18:11:05.925196+00:00 2021-04-04T18:11:07.767814+00:00 0:00:01.842618 13570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T18:11:03.467926+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T18:10:49.898725+00:00 2021-04-04T18:10:51.686348+00:00 0:00:01.787623 13569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T18:10:47.392347+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T17:00:00+00:00 PythonOperator 2021-04-04T18:10:41.621025+00:00 2021-04-04T18:10:44.538320+00:00 0:00:02.917295 13568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T18:10:39.386487+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T17:00:00+00:00 PythonOperator 2021-04-04T18:10:27.707575+00:00 2021-04-04T18:10:30.483896+00:00 0:00:02.776321 13567 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T18:10:25.347111+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T17:00:00+00:00 TriggerDagRunOperator 2021-04-04T18:10:19.797439+00:00 2021-04-04T18:10:20.309092+00:00 0:00:00.511653 13566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:10:17.344495+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T17:00:00+00:00 TriggerDagRunOperator 2021-04-04T18:10:19.588068+00:00 2021-04-04T18:10:20.018821+00:00 0:00:00.430753 13565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:10:17.344465+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T17:05:00+00:00 EmrJobFlowSensor 2021-04-04T18:06:01.324730+00:00 2021-04-04T18:16:04.132105+00:00 0:10:02.807375 13564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T18:05:59.011956+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T17:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T18:05:39.245178+00:00 2021-04-04T18:05:40.924607+00:00 0:00:01.679429 13563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T18:05:36.957356+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T17:05:00+00:00 PythonOperator 2021-04-04T18:05:17.113775+00:00 2021-04-04T18:05:19.791744+00:00 0:00:02.677969 13562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T18:05:14.956818+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T17:00:00+00:00 EmrJobFlowSensor 2021-04-04T18:00:52.707820+00:00 2021-04-04T18:09:55.350805+00:00 0:09:02.642985 13561 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T18:00:50.392419+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T17:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T18:00:30.650158+00:00 2021-04-04T18:00:32.504273+00:00 0:00:01.854115 13560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T18:00:28.346071+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T17:00:00+00:00 PythonOperator 2021-04-04T18:00:10.613335+00:00 2021-04-04T18:00:13.325253+00:00 0:00:02.711918 13559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T18:00:08.316108+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T16:00:00+00:00 EmrJobFlowSensor 2021-04-04T17:11:12.219742+00:00 2021-04-04T17:20:14.821707+00:00 0:09:02.601965 13557 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T17:11:10.035338+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T16:00:00+00:00 EmrJobFlowSensor 2021-04-04T17:11:08.215928+00:00 2021-04-04T17:21:10.997429+00:00 0:10:02.781501 13556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T17:11:06.022051+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T17:10:50.445737+00:00 2021-04-04T17:10:52.145255+00:00 0:00:01.699518 13555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T17:10:48.045471+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T17:10:46.738101+00:00 2021-04-04T17:10:48.427857+00:00 0:00:01.689756 13554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T17:10:44.058098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T16:00:00+00:00 PythonOperator 2021-04-04T17:10:28.304908+00:00 2021-04-04T17:10:31.001617+00:00 0:00:02.696709 13553 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T17:10:26.042112+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T16:00:00+00:00 PythonOperator 2021-04-04T17:10:26.480809+00:00 2021-04-04T17:10:29.556781+00:00 0:00:03.075972 13552 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T17:10:24.054833+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T16:00:00+00:00 TriggerDagRunOperator 2021-04-04T17:10:08.384634+00:00 2021-04-04T17:10:08.910488+00:00 0:00:00.525854 13551 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T17:10:05.951725+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T16:00:00+00:00 TriggerDagRunOperator 2021-04-04T17:10:08.245661+00:00 2021-04-04T17:10:08.739880+00:00 0:00:00.494219 13550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T17:10:05.951755+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T16:05:00+00:00 EmrJobFlowSensor 2021-04-04T17:05:47.780934+00:00 2021-04-04T17:14:50.349294+00:00 0:09:02.568360 13549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T17:05:45.584288+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T16:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T17:05:27.769047+00:00 2021-04-04T17:05:29.537507+00:00 0:00:01.768460 13548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T17:05:25.520935+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T16:05:00+00:00 PythonOperator 2021-04-04T17:05:05.782046+00:00 2021-04-04T17:05:08.536451+00:00 0:00:02.754405 13547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T17:05:03.502340+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T16:00:00+00:00 EmrJobFlowSensor 2021-04-04T17:00:51.326457+00:00 2021-04-04T17:09:53.938187+00:00 0:09:02.611730 13546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T17:00:49.064067+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T16:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T17:00:29.342375+00:00 2021-04-04T17:00:31.140148+00:00 0:00:01.797773 13545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T17:00:27.036674+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T16:00:00+00:00 PythonOperator 2021-04-04T17:00:09.409456+00:00 2021-04-04T17:00:12.305468+00:00 0:00:02.896012 13544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T17:00:07.018664+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T15:00:00+00:00 EmrJobFlowSensor 2021-04-04T16:12:40.004054+00:00 2021-04-04T16:21:42.783530+00:00 0:09:02.779476 13542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:12:37.688381+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T15:00:00+00:00 EmrJobFlowSensor 2021-04-04T16:12:37.991873+00:00 2021-04-04T16:22:40.793987+00:00 0:10:02.802114 13541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:12:35.703282+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T16:12:20.011853+00:00 2021-04-04T16:12:21.672542+00:00 0:00:01.660689 13540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T16:12:17.631348+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T16:12:15.908370+00:00 2021-04-04T16:12:17.683478+00:00 0:00:01.775108 13539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T16:12:13.626177+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T15:00:00+00:00 PythonOperator 2021-04-04T16:11:57.888461+00:00 2021-04-04T16:12:00.751098+00:00 0:00:02.862637 13538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T16:11:55.612468+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T15:00:00+00:00 PythonOperator 2021-04-04T16:11:55.887618+00:00 2021-04-04T16:11:58.855376+00:00 0:00:02.967758 13537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T16:11:53.610798+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T15:00:00+00:00 TriggerDagRunOperator 2021-04-04T16:11:41.809106+00:00 2021-04-04T16:11:42.219795+00:00 0:00:00.410689 13536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:11:39.598597+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T15:00:00+00:00 TriggerDagRunOperator 2021-04-04T16:11:41.824954+00:00 2021-04-04T16:11:42.349894+00:00 0:00:00.524940 13535 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:11:39.598560+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T15:05:00+00:00 EmrJobFlowSensor 2021-04-04T16:06:01.275083+00:00 2021-04-04T16:15:03.929047+00:00 0:09:02.653964 13534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T16:05:59.085444+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T15:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T16:05:35.289595+00:00 2021-04-04T16:05:37.013787+00:00 0:00:01.724192 13533 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T16:05:33.013467+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T15:05:00+00:00 PythonOperator 2021-04-04T16:05:13.188917+00:00 2021-04-04T16:05:15.874969+00:00 0:00:02.686052 13532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T16:05:10.995302+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T15:00:00+00:00 EmrJobFlowSensor 2021-04-04T16:01:02.971558+00:00 2021-04-04T16:11:05.726672+00:00 0:10:02.755114 13531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T16:01:00.583351+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T15:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T16:00:40.728682+00:00 2021-04-04T16:00:42.422535+00:00 0:00:01.693853 13530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T16:00:38.535035+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T15:00:00+00:00 PythonOperator 2021-04-04T16:00:20.749339+00:00 2021-04-04T16:00:23.658962+00:00 0:00:02.909623 13529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T16:00:18.508228+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T14:00:00+00:00 EmrJobFlowSensor 2021-04-04T15:22:55.554759+00:00 2021-04-04T15:31:58.307065+00:00 0:09:02.752306 13528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:22:53.058722+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T14:00:00+00:00 EmrJobFlowSensor 2021-04-04T15:22:51.353762+00:00 2021-04-04T15:33:54.304590+00:00 0:11:02.950828 13527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:22:49.048340+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T15:22:33.291105+00:00 2021-04-04T15:22:34.952382+00:00 0:00:01.661277 13526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T15:22:31.046781+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T15:22:29.208041+00:00 2021-04-04T15:22:30.957768+00:00 0:00:01.749727 13525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T15:22:26.940409+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T14:00:00+00:00 PythonOperator 2021-04-04T15:22:13.509725+00:00 2021-04-04T15:22:16.364035+00:00 0:00:02.854310 13524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T15:22:10.919375+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T14:00:00+00:00 PythonOperator 2021-04-04T15:22:09.383606+00:00 2021-04-04T15:22:12.858334+00:00 0:00:03.474728 13523 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T15:22:06.914557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T14:00:00+00:00 TriggerDagRunOperator 2021-04-04T15:21:53.513788+00:00 2021-04-04T15:21:54.180229+00:00 0:00:00.666441 13522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:21:50.900933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T14:00:00+00:00 TriggerDagRunOperator 2021-04-04T15:21:53.430119+00:00 2021-04-04T15:21:54.140734+00:00 0:00:00.710615 13521 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:21:50.900905+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T14:05:00+00:00 EmrJobFlowSensor 2021-04-04T15:05:58.898886+00:00 2021-04-04T15:15:01.614108+00:00 0:09:02.715222 13519 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T15:05:56.658698+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T14:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T15:05:37.083502+00:00 2021-04-04T15:05:38.721054+00:00 0:00:01.637552 13518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T15:05:34.614772+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T14:05:00+00:00 PythonOperator 2021-04-04T15:05:16.832772+00:00 2021-04-04T15:05:19.606868+00:00 0:00:02.774096 13517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T15:05:14.596516+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T14:00:00+00:00 EmrJobFlowSensor 2021-04-04T15:01:04.541569+00:00 2021-04-04T15:11:07.490955+00:00 0:10:02.949386 13516 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T15:01:02.208560+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T14:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T15:00:42.478029+00:00 2021-04-04T15:00:44.181195+00:00 0:00:01.703166 13515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T15:00:40.189909+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T14:00:00+00:00 PythonOperator 2021-04-04T15:00:22.329881+00:00 2021-04-04T15:00:25.096195+00:00 0:00:02.766314 13514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T15:00:20.160782+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T13:00:00+00:00 EmrJobFlowSensor 2021-04-04T14:10:11.730057+00:00 2021-04-04T14:19:14.364585+00:00 0:09:02.634528 13513 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:10:09.366193+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T13:00:00+00:00 EmrJobFlowSensor 2021-04-04T14:10:09.909594+00:00 2021-04-04T14:20:12.891905+00:00 0:10:02.982311 13512 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:10:07.378384+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:09:52.118137+00:00 2021-04-04T14:09:53.786950+00:00 0:00:01.668813 13511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T14:09:49.366498+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:09:49.754990+00:00 2021-04-04T14:09:51.832547+00:00 0:00:02.077557 13510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T14:09:47.356750+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T13:00:00+00:00 PythonOperator 2021-04-04T14:09:29.631245+00:00 2021-04-04T14:09:32.495450+00:00 0:00:02.864205 13509 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:09:27.269317+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T13:00:00+00:00 PythonOperator 2021-04-04T14:09:27.479323+00:00 2021-04-04T14:09:30.429289+00:00 0:00:02.949966 13508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:09:25.253142+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T13:00:00+00:00 TriggerDagRunOperator 2021-04-04T14:09:03.950092+00:00 2021-04-04T14:09:04.374602+00:00 0:00:00.424510 13507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:09:01.246538+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T13:00:00+00:00 TriggerDagRunOperator 2021-04-04T14:09:03.594856+00:00 2021-04-04T14:09:04.173886+00:00 0:00:00.579030 13506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:09:01.246510+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T13:05:00+00:00 EmrJobFlowSensor 2021-04-04T14:06:33.311413+00:00 2021-04-04T14:14:35.740139+00:00 0:08:02.428726 13505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T14:06:31.074040+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T13:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:05:39.536729+00:00 2021-04-04T14:05:41.252872+00:00 0:00:01.716143 13503 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T14:05:36.987762+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T13:05:00+00:00 PythonOperator 2021-04-04T14:05:17.088854+00:00 2021-04-04T14:05:19.866581+00:00 0:00:02.777727 13502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:05:14.908003+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T13:00:00+00:00 EmrJobFlowSensor 2021-04-04T14:00:48.685463+00:00 2021-04-04T14:08:51.177681+00:00 0:08:02.492218 13501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T14:00:46.426055+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T13:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T14:00:28.620007+00:00 2021-04-04T14:00:30.322511+00:00 0:00:01.702504 13500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T14:00:26.408728+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T13:00:00+00:00 PythonOperator 2021-04-04T14:00:06.746468+00:00 2021-04-04T14:00:09.562983+00:00 0:00:02.816515 13499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T14:00:04.388665+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T12:00:00+00:00 EmrJobFlowSensor 2021-04-04T13:12:16.179782+00:00 2021-04-04T13:21:18.922900+00:00 0:09:02.743118 13498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:12:13.793509+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T12:00:00+00:00 EmrJobFlowSensor 2021-04-04T13:12:04.068449+00:00 2021-04-04T13:22:06.889662+00:00 0:10:02.821213 13497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:12:01.700014+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:11:56.051206+00:00 2021-04-04T13:11:57.697828+00:00 0:00:01.646622 13496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T13:11:53.753144+00:00 2 default_pool