Task Instances

  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success vc-asset-import_v002 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
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:11:41.948204+00:00 2021-04-04T13:11:43.743093+00:00 0:00:01.794889 13495 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T13:11:39.676799+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:11:33.917928+00:00 2021-04-04T13:11:36.935375+00:00 0:00:03.017447 13494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:11:31.672764+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:11:21.936398+00:00 2021-04-04T13:11:24.766932+00:00 0:00:02.830534 13493 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:11:19.612404+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T12:00:00+00:00 TriggerDagRunOperator 2021-04-04T13:11:14.233283+00:00 2021-04-04T13:11:14.682388+00:00 0:00:00.449105 13492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:11:11.607877+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T12:00:00+00:00 TriggerDagRunOperator 2021-04-04T13:11:14.085451+00:00 2021-04-04T13:11:14.667636+00:00 0:00:00.582185 13491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:11:11.607913+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T12:05:00+00:00 EmrJobFlowSensor 2021-04-04T13:06:43.619241+00:00 2021-04-04T13:15:46.281566+00:00 0:09:02.662325 13490 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T13:06:41.233613+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:06:17.467868+00:00 2021-04-04T13:06:19.198898+00:00 0:00:01.731030 13489 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T13:06:15.217157+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-04T12:05:00+00:00 PythonOperator 2021-04-04T13:05:57.756022+00:00 2021-04-04T13:06:00.473722+00:00 0:00:02.717700 13488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:05:55.249489+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-04T12:00:00+00:00 EmrJobFlowSensor 2021-04-04T13:01:04.038764+00:00 2021-04-04T13:11:06.764465+00:00 0:10:02.725701 13486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T13:01:01.745364+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-04T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T13:00:41.911778+00:00 2021-04-04T13:00:43.598166+00:00 0:00:01.686388 13485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-04T13:00:39.693465+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-04T12:00:00+00:00 PythonOperator 2021-04-04T13:00:05.964176+00:00 2021-04-04T13:00:08.682362+00:00 0:00:02.718186 13484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-04T13:00:03.626304+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:11:08.985588+00:00 2021-04-04T12:20:11.672550+00:00 0:09:02.686962 13483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:11:06.745722+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-04T11:00:00+00:00 EmrJobFlowSensor 2021-04-04T12:11:05.161429+00:00 2021-04-04T12:20:07.920843+00:00 0:09:02.759414 13482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:11:02.747219+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:10:46.855425+00:00 2021-04-04T12:10:48.636784+00:00 0:00:01.781359 13481 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:10:44.618262+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-04T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:10:42.801689+00:00 2021-04-04T12:10:44.475281+00:00 0:00:01.673592 13480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:10:40.617030+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:10:25.106811+00:00 2021-04-04T12:10:28.243294+00:00 0:00:03.136483 13479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:10:22.666098+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-04T11:00:00+00:00 PythonOperator 2021-04-04T12:10:20.897106+00:00 2021-04-04T12:10:23.691980+00:00 0:00:02.794874 13478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-04T12:10:18.597093+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-04T11:00:00+00:00 TriggerDagRunOperator 2021-04-04T12:10:06.977972+00:00 2021-04-04T12:10:07.493044+00:00 0:00:00.515072 13477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:10:04.586258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-04T11:00:00+00:00 TriggerDagRunOperator 2021-04-04T12:10:06.789475+00:00 2021-04-04T12:10:07.196340+00:00 0:00:00.406865 13476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:10:04.586225+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-04T11:05:00+00:00 EmrJobFlowSensor 2021-04-04T12:06:04.697617+00:00 2021-04-04T12:15:07.312070+00:00 0:09:02.614453 13475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-04T12:06:02.247621+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-04T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-04T12:05:44.583965+00:00 2021-04-04T12:05:46.317780+00:00 0:00:01.733815 13474 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-04T12:05:42.173790+00:00 2 default_pool