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 booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T14:11:57.131999+00:00 2021-05-07T14:11:58.811767+00:00 0:00:01.679768 25489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T14:11:54.348408+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T14:11:54.845730+00:00 2021-05-07T14:11:56.847201+00:00 0:00:02.001471 25488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T14:11:52.360390+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T13:00:00+00:00 PythonOperator 2021-05-07T14:11:34.611831+00:00 2021-05-07T14:11:37.961388+00:00 0:00:03.349557 25487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T14:11:32.274413+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T13:00:00+00:00 PythonOperator 2021-05-07T14:11:32.873359+00:00 2021-05-07T14:11:35.936855+00:00 0:00:03.063496 25486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T14:11:30.370521+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T13:00:00+00:00 TriggerDagRunOperator 2021-05-07T14:11:16.520535+00:00 2021-05-07T14:11:17.058794+00:00 0:00:00.538259 25485 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T14:11:14.198592+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T13:00:00+00:00 TriggerDagRunOperator 2021-05-07T14:11:16.287212+00:00 2021-05-07T14:11:16.729514+00:00 0:00:00.442302 25484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T14:11:14.198561+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T13:05:00+00:00 EmrJobFlowSensor 2021-05-07T14:05:49.839322+00:00 2021-05-07T14:14:52.532068+00:00 0:09:02.692746 25483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T14:05:47.618056+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T14:05:28.091609+00:00 2021-05-07T14:05:29.897735+00:00 0:00:01.806126 25482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T14:05:25.662374+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T13:05:00+00:00 PythonOperator 2021-05-07T14:05:05.705144+00:00 2021-05-07T14:05:08.799555+00:00 0:00:03.094411 25481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T14:05:03.515064+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T13:00:00+00:00 EmrJobFlowSensor 2021-05-07T14:00:59.106288+00:00 2021-05-07T14:11:01.951578+00:00 0:10:02.845290 25480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T14:00:56.924564+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T14:00:39.512249+00:00 2021-05-07T14:00:41.306511+00:00 0:00:01.794262 25479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T14:00:36.947588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T13:00:00+00:00 PythonOperator 2021-05-07T14:00:17.057836+00:00 2021-05-07T14:00:20.095120+00:00 0:00:03.037284 25478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T14:00:14.835557+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T12:00:00+00:00 EmrJobFlowSensor 2021-05-07T13:17:11.477650+00:00 2021-05-07T13:27:14.408699+00:00 0:10:02.931049 25477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:17:09.241168+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T12:00:00+00:00 EmrJobFlowSensor 2021-05-07T13:16:58.083567+00:00 2021-05-07T13:26:00.725414+00:00 0:09:02.641847 25476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:16:55.344176+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T13:16:49.495907+00:00 2021-05-07T13:16:51.261189+00:00 0:00:01.765282 25475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T13:16:47.212567+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T13:16:35.821093+00:00 2021-05-07T13:16:37.687001+00:00 0:00:01.865908 25474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T13:16:33.253500+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T12:00:00+00:00 PythonOperator 2021-05-07T13:16:27.336172+00:00 2021-05-07T13:16:30.580718+00:00 0:00:03.244546 25473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T13:16:25.183207+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T12:00:00+00:00 PythonOperator 2021-05-07T13:16:15.464036+00:00 2021-05-07T13:16:18.617807+00:00 0:00:03.153771 25472 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T13:16:13.185658+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T12:00:00+00:00 TriggerDagRunOperator 2021-05-07T13:16:05.682449+00:00 2021-05-07T13:16:06.226402+00:00 0:00:00.543953 25471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:16:03.114488+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T12:00:00+00:00 TriggerDagRunOperator 2021-05-07T13:16:05.592985+00:00 2021-05-07T13:16:05.977326+00:00 0:00:00.384341 25470 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:16:03.114517+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T12:05:00+00:00 EmrJobFlowSensor 2021-05-07T13:06:11.642853+00:00 2021-05-07T13:15:14.221606+00:00 0:09:02.578753 25468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T13:06:09.481770+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T13:05:51.681049+00:00 2021-05-07T13:05:53.322330+00:00 0:00:01.641281 25467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T13:05:49.468608+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T12:05:00+00:00 PythonOperator 2021-05-07T13:05:19.828000+00:00 2021-05-07T13:05:22.864610+00:00 0:00:03.036610 25466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T13:05:17.465279+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T12:00:00+00:00 EmrJobFlowSensor 2021-05-07T13:01:07.112993+00:00 2021-05-07T13:10:09.801292+00:00 0:09:02.688299 25465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T13:01:04.992653+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T13:00:45.244109+00:00 2021-05-07T13:00:46.920713+00:00 0:00:01.676604 25464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T13:00:42.960704+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T12:00:00+00:00 PythonOperator 2021-05-07T13:00:25.182062+00:00 2021-05-07T13:00:28.348693+00:00 0:00:03.166631 25463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T13:00:22.838512+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T11:00:00+00:00 EmrJobFlowSensor 2021-05-07T12:11:09.367666+00:00 2021-05-07T12:20:12.091257+00:00 0:09:02.723591 25462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:11:06.853406+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T11:00:00+00:00 EmrJobFlowSensor 2021-05-07T12:11:05.088885+00:00 2021-05-07T12:23:08.119728+00:00 0:12:03.030843 25461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:11:02.856361+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T12:10:47.290152+00:00 2021-05-07T12:10:49.092829+00:00 0:00:01.802677 25460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T12:10:44.771784+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T12:10:40.972682+00:00 2021-05-07T12:10:42.784027+00:00 0:00:01.811345 25459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T12:10:38.704330+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T11:00:00+00:00 PythonOperator 2021-05-07T12:10:25.567109+00:00 2021-05-07T12:10:28.758209+00:00 0:00:03.191100 25458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T12:10:22.686581+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T11:05:00+00:00 EmrJobFlowSensor 2021-05-07T12:10:22.880036+00:00 2021-05-07T12:19:25.584528+00:00 0:09:02.704492 25457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:10:20.693952+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T11:00:00+00:00 PythonOperator 2021-05-07T12:10:20.788412+00:00 2021-05-07T12:10:24.757200+00:00 0:00:03.968788 25456 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T12:10:18.689186+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T12:10:03.599899+00:00 2021-05-07T12:10:05.283237+00:00 0:00:01.683338 25455 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T12:10:00.597115+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T11:00:00+00:00 TriggerDagRunOperator 2021-05-07T12:10:01.697476+00:00 2021-05-07T12:10:02.393593+00:00 0:00:00.696117 25454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:09:58.549067+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T11:00:00+00:00 TriggerDagRunOperator 2021-05-07T12:10:01.293524+00:00 2021-05-07T12:10:01.835471+00:00 0:00:00.541947 25453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T12:09:58.549096+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T11:05:00+00:00 PythonOperator 2021-05-07T12:05:07.496292+00:00 2021-05-07T12:05:10.524132+00:00 0:00:03.027840 25451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T12:05:05.073639+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T11:00:00+00:00 EmrJobFlowSensor 2021-05-07T12:00:48.922272+00:00 2021-05-07T12:09:51.694613+00:00 0:09:02.772341 25450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T12:00:46.441169+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T12:00:26.704991+00:00 2021-05-07T12:00:28.415323+00:00 0:00:01.710332 25449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T12:00:24.367081+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T11:00:00+00:00 PythonOperator 2021-05-07T12:00:06.494595+00:00 2021-05-07T12:00:09.536376+00:00 0:00:03.041781 25448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T12:00:04.269880+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T10:00:00+00:00 EmrJobFlowSensor 2021-05-07T11:11:26.156883+00:00 2021-05-07T11:22:29.215907+00:00 0:11:03.059024 25447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:11:24.029700+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T10:00:00+00:00 EmrJobFlowSensor 2021-05-07T11:11:20.176045+00:00 2021-05-07T11:20:22.764731+00:00 0:09:02.588686 25446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:11:18.020359+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T11:11:04.853673+00:00 2021-05-07T11:11:06.711806+00:00 0:00:01.858133 25445 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T11:11:02.141257+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T11:10:58.598184+00:00 2021-05-07T11:11:00.376483+00:00 0:00:01.778299 25444 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T11:10:56.058394+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T10:00:00+00:00 PythonOperator 2021-05-07T11:10:42.300924+00:00 2021-05-07T11:10:45.586429+00:00 0:00:03.285505 25443 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T11:10:40.048822+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T10:00:00+00:00 PythonOperator 2021-05-07T11:10:38.477628+00:00 2021-05-07T11:10:41.575148+00:00 0:00:03.097520 25442 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T11:10:36.054473+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T10:00:00+00:00 TriggerDagRunOperator 2021-05-07T11:10:28.644095+00:00 2021-05-07T11:10:29.162504+00:00 0:00:00.518409 25441 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:10:25.983099+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T10:00:00+00:00 TriggerDagRunOperator 2021-05-07T11:10:28.517944+00:00 2021-05-07T11:10:28.947245+00:00 0:00:00.429301 25440 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:10:25.983054+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T10:05:00+00:00 EmrJobFlowSensor 2021-05-07T11:06:11.582063+00:00 2021-05-07T11:15:14.093547+00:00 0:09:02.511484 25439 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T11:06:09.493904+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T11:05:51.466338+00:00 2021-05-07T11:05:53.106600+00:00 0:00:01.640262 25438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T11:05:49.419552+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T10:05:00+00:00 PythonOperator 2021-05-07T11:05:29.706169+00:00 2021-05-07T11:05:32.714313+00:00 0:00:03.008144 25437 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T11:05:27.403114+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T10:00:00+00:00 EmrJobFlowSensor 2021-05-07T11:01:00.919214+00:00 2021-05-07T11:10:03.557596+00:00 0:09:02.638382 25435 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T11:00:58.672152+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T11:00:38.936129+00:00 2021-05-07T11:00:40.745582+00:00 0:00:01.809453 25434 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T11:00:36.426939+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T10:00:00+00:00 PythonOperator 2021-05-07T11:00:17.246162+00:00 2021-05-07T11:00:20.341540+00:00 0:00:03.095378 25433 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T11:00:14.454274+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T09:00:00+00:00 EmrJobFlowSensor 2021-05-07T10:16:22.455222+00:00 2021-05-07T10:27:25.331629+00:00 0:11:02.876407 25432 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:16:20.322747+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T09:00:00+00:00 EmrJobFlowSensor 2021-05-07T10:15:58.516000+00:00 2021-05-07T10:25:01.310029+00:00 0:09:02.794029 25431 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:15:56.308748+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T10:15:52.696519+00:00 2021-05-07T10:15:54.398863+00:00 0:00:01.702344 25430 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T10:15:50.388719+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T10:15:36.647615+00:00 2021-05-07T10:15:38.376135+00:00 0:00:01.728520 25429 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T10:15:34.355247+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T09:00:00+00:00 PythonOperator 2021-05-07T10:15:30.751396+00:00 2021-05-07T10:15:34.054976+00:00 0:00:03.303580 25428 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T10:15:28.259126+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T09:00:00+00:00 PythonOperator 2021-05-07T10:15:06.266865+00:00 2021-05-07T10:15:09.370394+00:00 0:00:03.103529 25427 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T10:15:04.131350+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T09:00:00+00:00 TriggerDagRunOperator 2021-05-07T10:14:52.773873+00:00 2021-05-07T10:14:53.398401+00:00 0:00:00.624528 25426 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:14:50.124639+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T09:00:00+00:00 TriggerDagRunOperator 2021-05-07T10:14:52.474637+00:00 2021-05-07T10:14:52.911466+00:00 0:00:00.436829 25425 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:14:50.124680+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T09:05:00+00:00 EmrJobFlowSensor 2021-05-07T10:05:47.617430+00:00 2021-05-07T10:14:50.218246+00:00 0:09:02.600816 25424 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T10:05:45.370483+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T10:05:25.858871+00:00 2021-05-07T10:05:27.682891+00:00 0:00:01.824020 25423 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T10:05:23.306256+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T09:05:00+00:00 PythonOperator 2021-05-07T10:05:04.009777+00:00 2021-05-07T10:05:07.069076+00:00 0:00:03.059299 25422 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T10:05:01.359620+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T09:00:00+00:00 EmrJobFlowSensor 2021-05-07T10:04:31.334293+00:00 2021-05-07T10:14:34.159057+00:00 0:10:02.824764 25421 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T10:04:29.215066+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T10:04:09.612964+00:00 2021-05-07T10:04:11.330793+00:00 0:00:01.717829 25420 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T10:04:07.217380+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T09:00:00+00:00 PythonOperator 2021-05-07T10:00:19.338415+00:00 2021-05-07T10:00:22.382858+00:00 0:00:03.044443 25418 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T10:00:17.047320+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T08:00:00+00:00 EmrJobFlowSensor 2021-05-07T09:11:37.317761+00:00 2021-05-07T09:20:39.954559+00:00 0:09:02.636798 25417 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:11:34.977153+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T08:00:00+00:00 EmrJobFlowSensor 2021-05-07T09:11:29.193693+00:00 2021-05-07T09:23:32.251953+00:00 0:12:03.058260 25416 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:11:26.914078+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T09:11:15.721976+00:00 2021-05-07T09:11:17.424178+00:00 0:00:01.702202 25415 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T09:11:12.895164+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T09:11:06.978859+00:00 2021-05-07T09:11:08.670750+00:00 0:00:01.691891 25414 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T09:11:04.884378+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T08:00:00+00:00 PythonOperator 2021-05-07T09:10:53.357423+00:00 2021-05-07T09:10:56.464947+00:00 0:00:03.107524 25413 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T09:10:50.781520+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T08:00:00+00:00 PythonOperator 2021-05-07T09:10:45.247485+00:00 2021-05-07T09:10:48.564510+00:00 0:00:03.317025 25412 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T09:10:42.748824+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T08:00:00+00:00 TriggerDagRunOperator 2021-05-07T09:10:33.422382+00:00 2021-05-07T09:10:33.953384+00:00 0:00:00.531002 25411 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:10:30.706445+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T08:00:00+00:00 TriggerDagRunOperator 2021-05-07T09:10:33.165323+00:00 2021-05-07T09:10:33.598268+00:00 0:00:00.432945 25410 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:10:30.706399+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T08:05:00+00:00 EmrJobFlowSensor 2021-05-07T09:05:58.138851+00:00 2021-05-07T09:16:00.890104+00:00 0:10:02.751253 25409 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T09:05:56.055046+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T09:05:38.349383+00:00 2021-05-07T09:05:40.075158+00:00 0:00:01.725775 25408 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T09:05:36.036478+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T08:05:00+00:00 PythonOperator 2021-05-07T09:05:16.400742+00:00 2021-05-07T09:05:19.417933+00:00 0:00:03.017191 25407 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T09:05:14.073338+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T08:00:00+00:00 EmrJobFlowSensor 2021-05-07T09:01:16.027149+00:00 2021-05-07T09:10:18.775389+00:00 0:09:02.748240 25406 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T09:01:13.679405+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T09:00:53.863479+00:00 2021-05-07T09:00:55.582387+00:00 0:00:01.718908 25405 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T09:00:51.588588+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T08:00:00+00:00 PythonOperator 2021-05-07T09:00:34.289691+00:00 2021-05-07T09:00:37.391899+00:00 0:00:03.102208 25404 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T09:00:31.571000+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T07:00:00+00:00 EmrJobFlowSensor 2021-05-07T08:12:08.282821+00:00 2021-05-07T08:22:11.065288+00:00 0:10:02.782467 25402 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:12:06.007129+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T07:00:00+00:00 EmrJobFlowSensor 2021-05-07T08:12:06.094942+00:00 2021-05-07T08:22:08.860167+00:00 0:10:02.765225 25401 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:12:04.006443+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T08:11:46.301320+00:00 2021-05-07T08:11:47.979141+00:00 0:00:01.677821 25400 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T08:11:43.989880+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T08:11:42.101010+00:00 2021-05-07T08:11:43.921654+00:00 0:00:01.820644 25399 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T08:11:39.900272+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-07T07:00:00+00:00 PythonOperator 2021-05-07T08:11:26.991442+00:00 2021-05-07T08:11:30.141215+00:00 0:00:03.149773 25398 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T08:11:23.954166+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-07T07:00:00+00:00 PythonOperator 2021-05-07T08:11:22.101420+00:00 2021-05-07T08:11:25.856886+00:00 0:00:03.755466 25397 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T08:11:19.943764+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-07T07:00:00+00:00 TriggerDagRunOperator 2021-05-07T08:11:02.433763+00:00 2021-05-07T08:11:02.947156+00:00 0:00:00.513393 25396 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:10:59.657931+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-07T07:00:00+00:00 TriggerDagRunOperator 2021-05-07T08:11:02.088719+00:00 2021-05-07T08:11:02.484423+00:00 0:00:00.395704 25395 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:10:59.657879+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-07T07:05:00+00:00 EmrJobFlowSensor 2021-05-07T08:05:57.181940+00:00 2021-05-07T08:14:59.879161+00:00 0:09:02.697221 25394 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T08:05:54.941654+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-07T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-07T08:05:35.363338+00:00 2021-05-07T08:05:37.089090+00:00 0:00:01.725752 25393 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T08:05:32.953712+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-07T07:05:00+00:00 PythonOperator 2021-05-07T08:05:11.162887+00:00 2021-05-07T08:05:14.278114+00:00 0:00:03.115227 25392 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T08:05:08.879312+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-07T07:00:00+00:00 EmrJobFlowSensor 2021-05-07T08:00:46.442689+00:00 2021-05-07T08:10:49.471396+00:00 0:10:03.028707 25391 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-07T08:00:44.143292+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-07T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T08:00:26.656598+00:00 2021-05-07T08:00:28.522026+00:00 0:00:01.865428 25390 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-07T08:00:24.180432+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-07T07:00:00+00:00 PythonOperator 2021-05-07T08:00:04.493408+00:00 2021-05-07T08:00:07.565589+00:00 0:00:03.072181 25389 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-07T08:00:02.090033+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-07T06:00:00+00:00 EmrJobFlowSensor 2021-05-07T07:11:45.192376+00:00 2021-05-07T07:23:48.160138+00:00 0:12:02.967762 25387 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T07:11:42.904838+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-07T06:00:00+00:00 EmrJobFlowSensor 2021-05-07T07:11:27.035937+00:00 2021-05-07T07:20:29.668825+00:00 0:09:02.632888 25386 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-07T07:11:24.879110+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-07T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T07:11:23.005324+00:00 2021-05-07T07:11:24.730614+00:00 0:00:01.725290 25385 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T07:11:20.852542+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-07T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-07T07:11:01.080327+00:00 2021-05-07T07:11:02.928373+00:00 0:00:01.848046 25384 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-07T07:10:58.832252+00:00 2 default_pool