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 create_cluster_and_add_emr_steps 2021-05-10T13:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T14:05:36.171268+00:00 2021-05-10T14:05:37.921391+00:00 0:00:01.750123 26569 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T14:05:33.945735+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T13:05:00+00:00 PythonOperator 2021-05-10T14:05:12.068472+00:00 2021-05-10T14:05:15.114633+00:00 0:00:03.046161 26568 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T14:05:09.953709+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T13:00:00+00:00 EmrJobFlowSensor 2021-05-10T14:00:47.508026+00:00 2021-05-10T14:10:50.555348+00:00 0:10:03.047322 26567 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T14:00:45.300918+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T13:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T14:00:27.306446+00:00 2021-05-10T14:00:29.001998+00:00 0:00:01.695552 26566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T14:00:25.193794+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T13:00:00+00:00 PythonOperator 2021-05-10T14:00:05.414549+00:00 2021-05-10T14:00:08.530968+00:00 0:00:03.116419 26565 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T14:00:03.147749+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T12:00:00+00:00 EmrJobFlowSensor 2021-05-10T13:11:18.844635+00:00 2021-05-10T13:21:21.493254+00:00 0:10:02.648619 26563 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T13:11:16.476392+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T12:00:00+00:00 EmrJobFlowSensor 2021-05-10T13:11:12.666431+00:00 2021-05-10T13:22:15.643899+00:00 0:11:02.977468 26562 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T13:11:10.418484+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T13:10:58.732537+00:00 2021-05-10T13:11:00.380224+00:00 0:00:01.647687 26561 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T13:10:56.440732+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T13:10:50.911297+00:00 2021-05-10T13:10:52.759206+00:00 0:00:01.847909 26560 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T13:10:48.451319+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T12:00:00+00:00 PythonOperator 2021-05-10T13:10:36.573565+00:00 2021-05-10T13:10:39.726810+00:00 0:00:03.153245 26559 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T13:10:34.354471+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T12:00:00+00:00 PythonOperator 2021-05-10T13:10:30.676767+00:00 2021-05-10T13:10:33.967470+00:00 0:00:03.290703 26558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T13:10:28.382566+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T12:00:00+00:00 TriggerDagRunOperator 2021-05-10T13:10:10.818401+00:00 2021-05-10T13:10:11.347001+00:00 0:00:00.528600 26557 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T13:10:08.306957+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T12:00:00+00:00 TriggerDagRunOperator 2021-05-10T13:10:10.527850+00:00 2021-05-10T13:10:10.947744+00:00 0:00:00.419894 26556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T13:10:08.306919+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T12:05:00+00:00 EmrJobFlowSensor 2021-05-10T13:06:00.167130+00:00 2021-05-10T13:15:02.913987+00:00 0:09:02.746857 26555 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T13:05:57.960742+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T12:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T13:05:37.872326+00:00 2021-05-10T13:05:39.497492+00:00 0:00:01.625166 26554 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T13:05:35.702084+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T12:05:00+00:00 PythonOperator 2021-05-10T13:05:16.178696+00:00 2021-05-10T13:05:19.248967+00:00 0:00:03.070271 26553 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T13:05:13.671798+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T12:00:00+00:00 EmrJobFlowSensor 2021-05-10T13:00:57.008716+00:00 2021-05-10T13:09:59.736294+00:00 0:09:02.727578 26552 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T13:00:54.894534+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T12:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T13:00:37.103890+00:00 2021-05-10T13:00:38.813097+00:00 0:00:01.709207 26551 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T13:00:34.855200+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T12:00:00+00:00 PythonOperator 2021-05-10T13:00:15.161403+00:00 2021-05-10T13:00:18.279169+00:00 0:00:03.117766 26550 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T13:00:12.724919+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T11:00:00+00:00 EmrJobFlowSensor 2021-05-10T12:11:11.834627+00:00 2021-05-10T12:20:14.568063+00:00 0:09:02.733436 26548 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T12:11:09.557545+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T11:00:00+00:00 EmrJobFlowSensor 2021-05-10T12:10:53.621396+00:00 2021-05-10T12:20:56.441723+00:00 0:10:02.820327 26547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T12:10:51.422034+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T12:10:49.798420+00:00 2021-05-10T12:10:51.585373+00:00 0:00:01.786953 26546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T12:10:47.427285+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T12:10:33.673273+00:00 2021-05-10T12:10:35.470391+00:00 0:00:01.797118 26545 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T12:10:31.411658+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T11:00:00+00:00 PythonOperator 2021-05-10T12:10:29.907867+00:00 2021-05-10T12:10:33.064133+00:00 0:00:03.156266 26544 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T12:10:27.411682+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T11:00:00+00:00 PythonOperator 2021-05-10T12:10:09.727284+00:00 2021-05-10T12:10:13.115418+00:00 0:00:03.388134 26543 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T12:10:07.400783+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T11:00:00+00:00 TriggerDagRunOperator 2021-05-10T12:10:04.034245+00:00 2021-05-10T12:10:04.574891+00:00 0:00:00.540646 26542 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T12:10:01.466341+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T11:00:00+00:00 TriggerDagRunOperator 2021-05-10T12:10:03.975488+00:00 2021-05-10T12:10:04.390855+00:00 0:00:00.415367 26541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T12:10:01.466389+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T11:05:00+00:00 EmrJobFlowSensor 2021-05-10T12:05:50.830871+00:00 2021-05-10T12:14:53.355443+00:00 0:09:02.524572 26540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T12:05:48.741588+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T11:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T12:05:30.918859+00:00 2021-05-10T12:05:32.689600+00:00 0:00:01.770741 26539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T12:05:28.599542+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T11:05:00+00:00 PythonOperator 2021-05-10T12:05:08.917404+00:00 2021-05-10T12:05:12.041945+00:00 0:00:03.124541 26538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T12:05:06.554238+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T11:00:00+00:00 EmrJobFlowSensor 2021-05-10T12:00:56.104505+00:00 2021-05-10T12:09:58.989406+00:00 0:09:02.884901 26537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T12:00:53.950865+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T11:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T12:00:36.231147+00:00 2021-05-10T12:00:37.903671+00:00 0:00:01.672524 26536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T12:00:33.907599+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T11:00:00+00:00 PythonOperator 2021-05-10T12:00:12.039634+00:00 2021-05-10T12:00:15.168909+00:00 0:00:03.129275 26535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T12:00:09.797478+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T10:00:00+00:00 EmrJobFlowSensor 2021-05-10T11:12:17.317328+00:00 2021-05-10T11:23:20.191805+00:00 0:11:02.874477 26533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T11:12:15.029466+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T10:00:00+00:00 EmrJobFlowSensor 2021-05-10T11:12:09.223742+00:00 2021-05-10T11:22:12.103769+00:00 0:10:02.880027 26532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T11:12:07.043828+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T11:11:55.773512+00:00 2021-05-10T11:11:57.561309+00:00 0:00:01.787797 26531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T11:11:53.075675+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T11:11:47.220702+00:00 2021-05-10T11:11:48.893336+00:00 0:00:01.672634 26530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T11:11:44.999319+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T10:00:00+00:00 PythonOperator 2021-05-10T11:11:35.413200+00:00 2021-05-10T11:11:38.874377+00:00 0:00:03.461177 26529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T11:11:33.063236+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T10:00:00+00:00 PythonOperator 2021-05-10T11:11:27.319870+00:00 2021-05-10T11:11:30.420306+00:00 0:00:03.100436 26528 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T11:11:24.984653+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T10:00:00+00:00 TriggerDagRunOperator 2021-05-10T11:11:09.509808+00:00 2021-05-10T11:11:10.037142+00:00 0:00:00.527334 26527 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T11:11:06.890680+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T10:00:00+00:00 TriggerDagRunOperator 2021-05-10T11:11:09.332099+00:00 2021-05-10T11:11:09.742719+00:00 0:00:00.410620 26526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T11:11:06.890712+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T10:05:00+00:00 EmrJobFlowSensor 2021-05-10T11:06:08.428029+00:00 2021-05-10T11:14:10.976828+00:00 0:08:02.548799 26525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T11:06:06.073406+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T10:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T11:05:44.419169+00:00 2021-05-10T11:05:46.149690+00:00 0:00:01.730521 26524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T11:05:42.008123+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T10:05:00+00:00 PythonOperator 2021-05-10T11:05:24.140405+00:00 2021-05-10T11:05:27.274476+00:00 0:00:03.134071 26523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T11:05:21.990606+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T10:00:00+00:00 EmrJobFlowSensor 2021-05-10T11:00:55.632520+00:00 2021-05-10T11:10:58.638346+00:00 0:10:03.005826 26522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T11:00:53.292036+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T10:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T11:00:33.338503+00:00 2021-05-10T11:00:35.037926+00:00 0:00:01.699423 26521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T11:00:31.189094+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T10:00:00+00:00 PythonOperator 2021-05-10T11:00:13.782181+00:00 2021-05-10T11:00:17.036837+00:00 0:00:03.254656 26520 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T11:00:11.152861+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T09:00:00+00:00 EmrJobFlowSensor 2021-05-10T10:10:04.555768+00:00 2021-05-10T10:30:08.870382+00:00 0:20:04.314614 26518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T10:10:02.040130+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T09:00:00+00:00 EmrJobFlowSensor 2021-05-10T10:09:46.456663+00:00 2021-05-10T10:19:49.254623+00:00 0:10:02.797960 26517 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T10:09:44.161542+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T10:09:42.403839+00:00 2021-05-10T10:09:44.061247+00:00 0:00:01.657408 26516 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T10:09:40.146206+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T10:09:24.421241+00:00 2021-05-10T10:09:27.000919+00:00 0:00:02.579678 26515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T10:09:22.003603+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T09:00:00+00:00 PythonOperator 2021-05-10T10:09:22.297791+00:00 2021-05-10T10:09:25.463243+00:00 0:00:03.165452 26514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T10:09:20.008399+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T09:00:00+00:00 PythonOperator 2021-05-10T10:09:02.963836+00:00 2021-05-10T10:09:06.366673+00:00 0:00:03.402837 26513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T10:09:00.069627+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T09:00:00+00:00 TriggerDagRunOperator 2021-05-10T10:08:56.914156+00:00 2021-05-10T10:08:57.432484+00:00 0:00:00.518328 26512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T10:08:53.758513+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T09:00:00+00:00 TriggerDagRunOperator 2021-05-10T10:08:56.704663+00:00 2021-05-10T10:08:57.284425+00:00 0:00:00.579762 26511 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T10:08:53.758442+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T09:05:00+00:00 EmrJobFlowSensor 2021-05-10T10:05:56.085197+00:00 2021-05-10T10:14:58.866612+00:00 0:09:02.781415 26510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T10:05:53.461717+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T09:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T10:05:35.676478+00:00 2021-05-10T10:05:37.311215+00:00 0:00:01.634737 26509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T10:05:33.372421+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T09:05:00+00:00 PythonOperator 2021-05-10T10:05:11.379175+00:00 2021-05-10T10:05:14.550546+00:00 0:00:03.171371 26508 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T10:05:09.290892+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T09:00:00+00:00 EmrJobFlowSensor 2021-05-10T10:00:47.214135+00:00 2021-05-10T10:08:49.827310+00:00 0:08:02.613175 26507 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T10:00:44.706488+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T09:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T10:00:25.171040+00:00 2021-05-10T10:00:26.987442+00:00 0:00:01.816402 26506 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T10:00:22.748539+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T09:00:00+00:00 PythonOperator 2021-05-10T10:00:04.885383+00:00 2021-05-10T10:00:08.004536+00:00 0:00:03.119153 26505 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T10:00:02.644106+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T08:00:00+00:00 EmrJobFlowSensor 2021-05-10T09:22:07.781021+00:00 2021-05-10T09:31:10.327166+00:00 0:09:02.546145 26503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T09:22:05.523899+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T08:00:00+00:00 EmrJobFlowSensor 2021-05-10T09:21:57.681317+00:00 2021-05-10T09:31:00.374987+00:00 0:09:02.693670 26502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T09:21:55.505503+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T09:21:43.650340+00:00 2021-05-10T09:21:45.406505+00:00 0:00:01.756165 26501 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T09:21:41.503067+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T09:21:37.696200+00:00 2021-05-10T09:21:39.557659+00:00 0:00:01.861459 26500 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T09:21:35.493165+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T08:00:00+00:00 PythonOperator 2021-05-10T09:21:23.675687+00:00 2021-05-10T09:21:27.165275+00:00 0:00:03.489588 26499 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T09:21:21.434205+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T08:00:00+00:00 PythonOperator 2021-05-10T09:21:15.807013+00:00 2021-05-10T09:21:18.942207+00:00 0:00:03.135194 26498 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T09:21:13.404058+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T08:00:00+00:00 TriggerDagRunOperator 2021-05-10T09:21:11.757205+00:00 2021-05-10T09:21:12.278289+00:00 0:00:00.521084 26497 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T09:21:09.393121+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T08:00:00+00:00 TriggerDagRunOperator 2021-05-10T09:21:11.529016+00:00 2021-05-10T09:21:11.945078+00:00 0:00:00.416062 26496 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T09:21:09.393089+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T08:05:00+00:00 EmrJobFlowSensor 2021-05-10T09:05:47.751381+00:00 2021-05-10T09:14:50.419605+00:00 0:09:02.668224 26495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T09:05:45.544791+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T08:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T09:05:27.545379+00:00 2021-05-10T09:05:29.165292+00:00 0:00:01.619913 26494 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T09:05:25.418472+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T08:05:00+00:00 PythonOperator 2021-05-10T09:05:05.528380+00:00 2021-05-10T09:05:08.564507+00:00 0:00:03.036127 26493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T09:05:03.392576+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T08:00:00+00:00 EmrJobFlowSensor 2021-05-10T09:00:49.130983+00:00 2021-05-10T09:20:53.558381+00:00 0:20:04.427398 26492 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T09:00:46.719382+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T08:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T09:00:27.244680+00:00 2021-05-10T09:00:29.042175+00:00 0:00:01.797495 26491 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T09:00:24.775028+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T08:00:00+00:00 PythonOperator 2021-05-10T09:00:07.157671+00:00 2021-05-10T09:00:10.301598+00:00 0:00:03.143927 26490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T09:00:04.686177+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T07:00:00+00:00 EmrJobFlowSensor 2021-05-10T08:11:27.933677+00:00 2021-05-10T08:22:30.945201+00:00 0:11:03.011524 26488 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T08:11:25.563149+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T07:00:00+00:00 EmrJobFlowSensor 2021-05-10T08:11:07.765676+00:00 2021-05-10T08:20:10.520080+00:00 0:09:02.754404 26487 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T08:11:05.556905+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T08:10:57.730396+00:00 2021-05-10T08:10:59.425856+00:00 0:00:01.695460 26486 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T08:10:55.583834+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T08:10:45.687248+00:00 2021-05-10T08:10:47.442932+00:00 0:00:01.755684 26485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T08:10:43.521642+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T07:00:00+00:00 PythonOperator 2021-05-10T08:10:35.665483+00:00 2021-05-10T08:10:38.938973+00:00 0:00:03.273490 26484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T08:10:33.516620+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T07:00:00+00:00 PythonOperator 2021-05-10T08:10:24.093030+00:00 2021-05-10T08:10:27.172082+00:00 0:00:03.079052 26483 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T08:10:21.509891+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T07:00:00+00:00 TriggerDagRunOperator 2021-05-10T08:10:15.864545+00:00 2021-05-10T08:10:16.398394+00:00 0:00:00.533849 26482 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T08:10:13.502801+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T07:00:00+00:00 TriggerDagRunOperator 2021-05-10T08:10:15.764878+00:00 2021-05-10T08:10:16.151307+00:00 0:00:00.386429 26481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T08:10:13.502833+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T07:05:00+00:00 EmrJobFlowSensor 2021-05-10T08:06:02.949028+00:00 2021-05-10T08:15:05.535623+00:00 0:09:02.586595 26480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T08:06:00.819414+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T07:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T08:05:41.164158+00:00 2021-05-10T08:05:42.910116+00:00 0:00:01.745958 26479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T08:05:38.864899+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T07:05:00+00:00 PythonOperator 2021-05-10T08:05:19.418783+00:00 2021-05-10T08:05:22.488335+00:00 0:00:03.069552 26478 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T08:05:16.777871+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-05-10T07:00:00+00:00 EmrJobFlowSensor 2021-05-10T08:00:50.465765+00:00 2021-05-10T08:09:53.410567+00:00 0:09:02.944802 26477 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T08:00:48.109486+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-05-10T07:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T08:00:28.211282+00:00 2021-05-10T08:00:29.938140+00:00 0:00:01.726858 26476 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-05-10T08:00:26.040206+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-05-10T07:00:00+00:00 PythonOperator 2021-05-10T08:00:08.198944+00:00 2021-05-10T08:00:11.305429+00:00 0:00:03.106485 26475 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-05-10T08:00:05.924567+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-05-10T06:00:00+00:00 EmrJobFlowSensor 2021-05-10T07:11:10.498666+00:00 2021-05-10T07:21:13.243745+00:00 0:10:02.745079 26473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T07:11:08.165080+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-05-10T06:00:00+00:00 EmrJobFlowSensor 2021-05-10T07:10:58.303074+00:00 2021-05-10T07:21:01.110662+00:00 0:10:02.807588 26472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T07:10:56.094458+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-05-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T07:10:48.413036+00:00 2021-05-10T07:10:50.100260+00:00 0:00:01.687224 26471 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T07:10:46.082158+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-05-10T06:00:00+00:00 EmrCreateJobFlowOperator 2021-05-10T07:10:38.410279+00:00 2021-05-10T07:10:40.231894+00:00 0:00:01.821615 26470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T07:10:36.074729+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-05-10T06:00:00+00:00 PythonOperator 2021-05-10T07:10:26.487060+00:00 2021-05-10T07:10:29.637987+00:00 0:00:03.150927 26469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T07:10:24.077849+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-05-10T06:00:00+00:00 PythonOperator 2021-05-10T07:10:16.119012+00:00 2021-05-10T07:10:19.406775+00:00 0:00:03.287763 26468 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T07:10:13.995686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-05-10T06:00:00+00:00 TriggerDagRunOperator 2021-05-10T07:10:10.702845+00:00 2021-05-10T07:10:11.244664+00:00 0:00:00.541819 26467 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T07:10:08.060686+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-05-10T06:00:00+00:00 TriggerDagRunOperator 2021-05-10T07:10:10.371774+00:00 2021-05-10T07:10:10.765383+00:00 0:00:00.393609 26466 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T07:10:08.060645+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-05-10T06:05:00+00:00 EmrJobFlowSensor 2021-05-10T07:06:15.732953+00:00 2021-05-10T07:15:18.383975+00:00 0:09:02.651022 26465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-05-10T07:06:13.599905+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-05-10T06:05:00+00:00 EmrCreateJobFlowOperator 2021-05-10T07:05:56.135949+00:00 2021-05-10T07:05:57.993465+00:00 0:00:01.857516 26464 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-05-10T07:05:53.587508+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-05-10T06:05:00+00:00 PythonOperator 2021-05-10T07:05:33.645494+00:00 2021-05-10T07:05:36.767454+00:00 0:00:03.121960 26463 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-05-10T07:05:31.538205+00:00 2 default_pool