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-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T12:00:00+00:00 TriggerDagRunOperator 2021-03-25T13:09:59.014946+00:00 2021-03-25T13:09:59.409575+00:00 0:00:00.394629 11586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:09:56.834712+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T12:05:00+00:00 EmrJobFlowSensor 2021-03-25T13:06:12.771326+00:00 2021-03-25T13:15:15.352545+00:00 0:09:02.581219 11585 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T13:06:10.558813+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T12:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T13:05:50.648983+00:00 2021-03-25T13:05:52.326921+00:00 0:00:01.677938 11584 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T13:05:48.487806+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T12:05:00+00:00 PythonOperator 2021-03-25T13:05:22.609095+00:00 2021-03-25T13:05:25.383073+00:00 0:00:02.773978 11583 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T13:05:20.399786+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T12:00:00+00:00 EmrJobFlowSensor 2021-03-25T13:00:48.150688+00:00 2021-03-25T13:09:50.616439+00:00 0:09:02.465751 11582 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T13:00:45.915974+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T12:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T13:00:26.093977+00:00 2021-03-25T13:00:27.772358+00:00 0:00:01.678381 11581 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T13:00:23.910778+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T12:00:00+00:00 PythonOperator 2021-03-25T13:00:04.173339+00:00 2021-03-25T13:00:07.011119+00:00 0:00:02.837780 11580 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T13:00:01.853649+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T11:00:00+00:00 EmrJobFlowSensor 2021-03-25T12:10:59.529259+00:00 2021-03-25T12:21:02.389943+00:00 0:10:02.860684 11578 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:57.322572+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T12:10:39.684144+00:00 2021-03-25T12:10:41.497592+00:00 0:00:01.813448 11577 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T12:10:37.303264+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T11:00:00+00:00 PythonOperator 2021-03-25T12:10:17.426373+00:00 2021-03-25T12:10:20.379799+00:00 0:00:02.953426 11576 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T12:10:15.267065+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T11:00:00+00:00 TriggerDagRunOperator 2021-03-25T12:10:07.618661+00:00 2021-03-25T12:10:08.112012+00:00 0:00:00.493351 11575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:05.271365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T11:00:00+00:00 TriggerDagRunOperator 2021-03-25T12:10:07.447815+00:00 2021-03-25T12:10:07.862438+00:00 0:00:00.414623 11574 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:10:05.271336+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T11:05:00+00:00 EmrJobFlowSensor 2021-03-25T12:05:59.490668+00:00 2021-03-25T12:15:02.185559+00:00 0:09:02.694891 11573 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T12:05:57.057027+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T11:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T12:05:39.270973+00:00 2021-03-25T12:05:40.978771+00:00 0:00:01.707798 11572 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T12:05:37.059884+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T11:05:00+00:00 PythonOperator 2021-03-25T12:05:17.168089+00:00 2021-03-25T12:05:19.905965+00:00 0:00:02.737876 11571 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T12:05:14.949284+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T11:00:00+00:00 EmrJobFlowSensor 2021-03-25T12:00:48.756839+00:00 2021-03-25T12:09:51.534244+00:00 0:09:02.777405 11570 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T12:00:46.489889+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T11:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T12:00:28.708215+00:00 2021-03-25T12:00:30.386645+00:00 0:00:01.678430 11569 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T12:00:26.476695+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T11:00:00+00:00 PythonOperator 2021-03-25T12:00:06.968765+00:00 2021-03-25T12:00:09.803555+00:00 0:00:02.834790 11568 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T12:00:04.456599+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T10:00:00+00:00 EmrJobFlowSensor 2021-03-25T11:11:22.140035+00:00 2021-03-25T11:23:25.467449+00:00 0:12:03.327414 11566 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:11:19.825863+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T11:10:57.927980+00:00 2021-03-25T11:10:59.652264+00:00 0:00:01.724284 11565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T11:10:55.807055+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T10:00:00+00:00 PythonOperator 2021-03-25T11:10:33.989354+00:00 2021-03-25T11:10:37.005037+00:00 0:00:03.015683 11564 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T11:10:31.784390+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T10:00:00+00:00 TriggerDagRunOperator 2021-03-25T11:10:16.287265+00:00 2021-03-25T11:10:16.682551+00:00 0:00:00.395286 11563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:10:13.755599+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T10:00:00+00:00 TriggerDagRunOperator 2021-03-25T11:10:16.106581+00:00 2021-03-25T11:10:16.645382+00:00 0:00:00.538801 11562 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:10:13.755563+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T10:05:00+00:00 EmrJobFlowSensor 2021-03-25T11:06:11.492642+00:00 2021-03-25T11:15:14.042566+00:00 0:09:02.549924 11561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T11:06:09.322730+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T10:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T11:05:51.401517+00:00 2021-03-25T11:05:53.038665+00:00 0:00:01.637148 11560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T11:05:49.302708+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T10:05:00+00:00 PythonOperator 2021-03-25T11:05:29.763091+00:00 2021-03-25T11:05:32.540523+00:00 0:00:02.777432 11559 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T11:05:27.363098+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T10:00:00+00:00 EmrJobFlowSensor 2021-03-25T11:01:06.911797+00:00 2021-03-25T11:10:09.630949+00:00 0:09:02.719152 11558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T11:01:04.787406+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T10:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T11:00:45.084282+00:00 2021-03-25T11:00:46.958361+00:00 0:00:01.874079 11557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T11:00:42.759571+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T10:00:00+00:00 PythonOperator 2021-03-25T11:00:23.381369+00:00 2021-03-25T11:00:26.507716+00:00 0:00:03.126347 11556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T11:00:20.766644+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T09:00:00+00:00 EmrJobFlowSensor 2021-03-25T10:12:16.331679+00:00 2021-03-25T10:22:19.208439+00:00 0:10:02.876760 11554 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:12:14.040541+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T10:11:56.411907+00:00 2021-03-25T10:11:58.228203+00:00 0:00:01.816296 11553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T10:11:54.016300+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T09:00:00+00:00 PythonOperator 2021-03-25T10:11:34.208313+00:00 2021-03-25T10:11:37.189018+00:00 0:00:02.980705 11552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T10:11:31.993894+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T09:00:00+00:00 TriggerDagRunOperator 2021-03-25T10:11:16.247751+00:00 2021-03-25T10:11:16.667547+00:00 0:00:00.419796 11551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:11:13.945140+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T09:00:00+00:00 TriggerDagRunOperator 2021-03-25T10:11:16.210494+00:00 2021-03-25T10:11:16.740736+00:00 0:00:00.530242 11550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:11:13.945105+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T09:05:00+00:00 EmrJobFlowSensor 2021-03-25T10:05:57.695956+00:00 2021-03-25T10:15:00.290047+00:00 0:09:02.594091 11549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T10:05:55.503806+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T09:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T10:05:37.645200+00:00 2021-03-25T10:05:39.235434+00:00 0:00:01.590234 11548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T10:05:35.435810+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T09:05:00+00:00 PythonOperator 2021-03-25T10:05:15.628017+00:00 2021-03-25T10:05:18.402718+00:00 0:00:02.774701 11547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T10:05:13.381891+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T09:00:00+00:00 EmrJobFlowSensor 2021-03-25T10:01:05.072783+00:00 2021-03-25T10:11:07.937862+00:00 0:10:02.865079 11546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T10:01:02.912807+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T09:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T10:00:43.130032+00:00 2021-03-25T10:00:44.955749+00:00 0:00:01.825717 11545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T10:00:40.891037+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T09:00:00+00:00 PythonOperator 2021-03-25T10:00:21.502964+00:00 2021-03-25T10:00:24.233654+00:00 0:00:02.730690 11544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T10:00:18.872932+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T08:00:00+00:00 EmrJobFlowSensor 2021-03-25T09:11:18.004302+00:00 2021-03-25T09:21:20.890605+00:00 0:10:02.886303 11542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:11:15.791973+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T09:10:56.212813+00:00 2021-03-25T09:10:57.932868+00:00 0:00:01.720055 11541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T09:10:53.859376+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T08:00:00+00:00 PythonOperator 2021-03-25T09:10:34.207141+00:00 2021-03-25T09:10:37.252826+00:00 0:00:03.045685 11540 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T09:10:31.741019+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T08:00:00+00:00 TriggerDagRunOperator 2021-03-25T09:10:08.177839+00:00 2021-03-25T09:10:08.673844+00:00 0:00:00.496005 11539 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:10:05.653010+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T08:00:00+00:00 TriggerDagRunOperator 2021-03-25T09:10:08.135616+00:00 2021-03-25T09:10:08.686148+00:00 0:00:00.550532 11538 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:10:05.653052+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T08:05:00+00:00 EmrJobFlowSensor 2021-03-25T09:05:55.459749+00:00 2021-03-25T09:13:57.864578+00:00 0:08:02.404829 11537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T09:05:53.279889+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T08:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T09:05:33.570395+00:00 2021-03-25T09:05:35.212530+00:00 0:00:01.642135 11536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T09:05:31.262284+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T08:05:00+00:00 PythonOperator 2021-03-25T09:05:11.365474+00:00 2021-03-25T09:05:14.071324+00:00 0:00:02.705850 11535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T09:05:09.244976+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T08:00:00+00:00 EmrJobFlowSensor 2021-03-25T09:00:58.843655+00:00 2021-03-25T09:10:01.519494+00:00 0:09:02.675839 11534 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T09:00:56.631968+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T08:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T09:00:38.916993+00:00 2021-03-25T09:00:40.590359+00:00 0:00:01.673366 11533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T09:00:36.611991+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T08:00:00+00:00 PythonOperator 2021-03-25T09:00:17.273525+00:00 2021-03-25T09:00:20.031495+00:00 0:00:02.757970 11532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T09:00:14.662881+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T07:00:00+00:00 EmrJobFlowSensor 2021-03-25T08:11:57.595976+00:00 2021-03-25T08:23:00.486939+00:00 0:11:02.890963 11530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:11:55.420996+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T08:11:35.780488+00:00 2021-03-25T08:11:37.503443+00:00 0:00:01.722955 11529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T08:11:33.469494+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T07:00:00+00:00 PythonOperator 2021-03-25T08:11:13.681135+00:00 2021-03-25T08:11:16.745198+00:00 0:00:03.064063 11528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T08:11:11.384693+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T07:00:00+00:00 TriggerDagRunOperator 2021-03-25T08:10:57.673105+00:00 2021-03-25T08:10:58.067104+00:00 0:00:00.393999 11527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:10:55.324353+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T07:00:00+00:00 TriggerDagRunOperator 2021-03-25T08:10:57.626414+00:00 2021-03-25T08:10:58.127822+00:00 0:00:00.501408 11526 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:10:55.324324+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T07:05:00+00:00 EmrJobFlowSensor 2021-03-25T08:06:04.963748+00:00 2021-03-25T08:14:07.384910+00:00 0:08:02.421162 11525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T08:06:02.775165+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T07:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T08:05:43.083748+00:00 2021-03-25T08:05:44.758121+00:00 0:00:01.674373 11524 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T08:05:40.718616+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T07:05:00+00:00 PythonOperator 2021-03-25T08:05:22.807324+00:00 2021-03-25T08:05:25.515071+00:00 0:00:02.707747 11523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T08:05:20.702633+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T07:00:00+00:00 EmrJobFlowSensor 2021-03-25T08:00:48.391874+00:00 2021-03-25T08:10:51.173511+00:00 0:10:02.781637 11522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T08:00:46.303901+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T07:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T08:00:26.590399+00:00 2021-03-25T08:00:28.290160+00:00 0:00:01.699761 11521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T08:00:24.369692+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T07:00:00+00:00 PythonOperator 2021-03-25T08:00:04.697355+00:00 2021-03-25T08:00:07.565744+00:00 0:00:02.868389 11520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T08:00:02.211415+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T06:00:00+00:00 EmrJobFlowSensor 2021-03-25T07:11:14.501270+00:00 2021-03-25T07:20:17.062985+00:00 0:09:02.561715 11518 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T07:11:12.151094+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T07:10:54.523383+00:00 2021-03-25T07:10:56.302806+00:00 0:00:01.779423 11517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T07:10:52.059133+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T06:00:00+00:00 PythonOperator 2021-03-25T07:10:32.630217+00:00 2021-03-25T07:10:35.628065+00:00 0:00:02.997848 11516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T07:10:29.988206+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T06:00:00+00:00 TriggerDagRunOperator 2021-03-25T07:10:28.315264+00:00 2021-03-25T07:10:28.721426+00:00 0:00:00.406162 11515 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T07:10:25.971520+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T06:00:00+00:00 TriggerDagRunOperator 2021-03-25T07:10:28.299031+00:00 2021-03-25T07:10:28.865202+00:00 0:00:00.566171 11514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T07:10:25.971476+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T06:05:00+00:00 EmrJobFlowSensor 2021-03-25T07:06:03.651232+00:00 2021-03-25T07:14:06.202644+00:00 0:08:02.551412 11513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T07:06:01.463372+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T06:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T07:05:37.649666+00:00 2021-03-25T07:05:39.326177+00:00 0:00:01.676511 11512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T07:05:35.504522+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T06:05:00+00:00 PythonOperator 2021-03-25T07:05:15.965930+00:00 2021-03-25T07:05:18.796267+00:00 0:00:02.830337 11511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T07:05:13.475893+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T06:00:00+00:00 EmrJobFlowSensor 2021-03-25T07:01:07.266548+00:00 2021-03-25T07:10:09.910960+00:00 0:09:02.644412 11510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T07:01:05.057749+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T06:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T07:00:43.203514+00:00 2021-03-25T07:00:44.902252+00:00 0:00:01.698738 11509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T07:00:41.011230+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T06:00:00+00:00 PythonOperator 2021-03-25T07:00:23.789360+00:00 2021-03-25T07:00:26.619095+00:00 0:00:02.829735 11508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T07:00:21.051669+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T05:00:00+00:00 EmrJobFlowSensor 2021-03-25T06:11:54.798185+00:00 2021-03-25T06:21:57.623682+00:00 0:10:02.825497 11506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T06:11:52.658316+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T06:11:32.824902+00:00 2021-03-25T06:11:34.502976+00:00 0:00:01.678074 11505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T06:11:30.616268+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T05:00:00+00:00 PythonOperator 2021-03-25T06:11:11.129473+00:00 2021-03-25T06:11:14.118093+00:00 0:00:02.988620 11504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T06:11:08.595156+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T05:00:00+00:00 TriggerDagRunOperator 2021-03-25T06:10:58.980321+00:00 2021-03-25T06:10:59.379400+00:00 0:00:00.399079 11503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T06:10:56.535924+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T05:00:00+00:00 TriggerDagRunOperator 2021-03-25T06:10:58.878341+00:00 2021-03-25T06:10:59.407856+00:00 0:00:00.529515 11502 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T06:10:56.535898+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T05:05:00+00:00 EmrJobFlowSensor 2021-03-25T06:06:04.389812+00:00 2021-03-25T06:15:06.827965+00:00 0:09:02.438153 11501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T06:06:02.156161+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T05:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T06:05:42.481443+00:00 2021-03-25T06:05:44.134261+00:00 0:00:01.652818 11500 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T06:05:40.156754+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T05:05:00+00:00 PythonOperator 2021-03-25T06:05:22.280611+00:00 2021-03-25T06:05:24.976121+00:00 0:00:02.695510 11499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T06:05:20.033007+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T05:00:00+00:00 EmrJobFlowSensor 2021-03-25T06:00:49.690906+00:00 2021-03-25T06:10:52.515239+00:00 0:10:02.824333 11498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T06:00:47.543477+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T05:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T06:00:27.781007+00:00 2021-03-25T06:00:29.543501+00:00 0:00:01.762494 11497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T06:00:25.521366+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T05:00:00+00:00 PythonOperator 2021-03-25T06:00:06.316329+00:00 2021-03-25T06:00:09.151424+00:00 0:00:02.835095 11496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T06:00:03.552239+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T04:00:00+00:00 EmrJobFlowSensor 2021-03-25T05:10:09.221696+00:00 2021-03-25T05:20:11.923056+00:00 0:10:02.701360 11494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T05:10:06.949059+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T05:09:47.161739+00:00 2021-03-25T05:09:48.978519+00:00 0:00:01.816780 11493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T05:09:44.772702+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T04:00:00+00:00 PythonOperator 2021-03-25T05:09:26.989926+00:00 2021-03-25T05:09:29.982812+00:00 0:00:02.992886 11492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T05:09:24.706332+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-03-25T04:00:00+00:00 TriggerDagRunOperator 2021-03-25T05:09:19.030114+00:00 2021-03-25T05:09:19.731775+00:00 0:00:00.701661 11491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T05:09:16.697921+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T04:00:00+00:00 TriggerDagRunOperator 2021-03-25T05:09:18.956392+00:00 2021-03-25T05:09:19.348917+00:00 0:00:00.392525 11490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T05:09:16.697952+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-03-25T04:05:00+00:00 EmrJobFlowSensor 2021-03-25T05:05:54.784296+00:00 2021-03-25T05:13:57.253715+00:00 0:08:02.469419 11489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T05:05:52.368756+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-03-25T04:05:00+00:00 EmrCreateJobFlowOperator 2021-03-25T05:05:32.452821+00:00 2021-03-25T05:05:34.105851+00:00 0:00:01.653030 11488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T05:05:30.303933+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-03-25T04:05:00+00:00 PythonOperator 2021-03-25T05:05:12.353888+00:00 2021-03-25T05:05:15.099611+00:00 0:00:02.745723 11487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T05:05:10.287543+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-03-25T04:00:00+00:00 EmrJobFlowSensor 2021-03-25T05:01:06.355083+00:00 2021-03-25T05:09:08.980833+00:00 0:08:02.625750 11486 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T05:01:03.882275+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-03-25T04:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T05:00:38.071051+00:00 2021-03-25T05:00:39.842927+00:00 0:00:01.771876 11485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-03-25T05:00:35.810540+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-03-25T04:00:00+00:00 PythonOperator 2021-03-25T05:00:12.424847+00:00 2021-03-25T05:00:15.326644+00:00 0:00:02.901797 11484 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-03-25T05:00:09.792237+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-03-25T03:00:00+00:00 EmrJobFlowSensor 2021-03-25T04:11:20.724463+00:00 2021-03-25T04:21:23.603684+00:00 0:10:02.879221 11482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T04:11:18.531406+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-03-25T03:00:00+00:00 EmrCreateJobFlowOperator 2021-03-25T04:10:58.814462+00:00 2021-03-25T04:11:00.745910+00:00 0:00:01.931448 11481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-03-25T04:10:56.517118+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-03-25T03:00:00+00:00 PythonOperator 2021-03-25T04:10:48.843812+00:00 2021-03-25T04:10:51.526583+00:00 0:00:02.682771 11480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T04:10:46.505404+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-03-25T03:00:00+00:00 PythonOperator 2021-03-25T04:10:37.088033+00:00 2021-03-25T04:10:40.177332+00:00 0:00:03.089299 11479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-03-25T04:10:34.505238+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-03-25T03:00:00+00:00 TriggerDagRunOperator 2021-03-25T04:10:25.145689+00:00 2021-03-25T04:10:25.692154+00:00 0:00:00.546465 11478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-03-25T04:10:22.643631+00:00 2 default_pool