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-04-18T12:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T13:05:35.247420+00:00 2021-04-18T13:05:36.888792+00:00 0:00:01.641372 18550 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T13:05:32.986075+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T12:05:00+00:00 PythonOperator 2021-04-18T13:05:13.226519+00:00 2021-04-18T13:05:16.095639+00:00 0:00:02.869120 18549 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T13:05:10.965260+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T12:00:00+00:00 EmrJobFlowSensor 2021-04-18T13:00:54.878257+00:00 2021-04-18T13:08:57.414974+00:00 0:08:02.536717 18548 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T13:00:52.549376+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T12:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T13:00:34.924405+00:00 2021-04-18T13:00:36.709061+00:00 0:00:01.784656 18547 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T13:00:32.436131+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T12:00:00+00:00 PythonOperator 2021-04-18T13:00:10.816115+00:00 2021-04-18T13:00:13.948526+00:00 0:00:03.132411 18546 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T13:00:08.414156+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T11:00:00+00:00 EmrJobFlowSensor 2021-04-18T12:11:10.201191+00:00 2021-04-18T12:20:12.968540+00:00 0:09:02.767349 18545 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T12:11:07.899939+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T11:00:00+00:00 EmrJobFlowSensor 2021-04-18T12:11:08.313356+00:00 2021-04-18T12:20:11.399910+00:00 0:09:03.086554 18544 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T12:11:05.962026+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T12:10:50.231381+00:00 2021-04-18T12:10:52.053799+00:00 0:00:01.822418 18543 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T12:10:47.888302+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T12:10:48.129031+00:00 2021-04-18T12:10:49.829019+00:00 0:00:01.699988 18542 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T12:10:45.892341+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T11:00:00+00:00 PythonOperator 2021-04-18T12:10:28.674844+00:00 2021-04-18T12:10:31.958501+00:00 0:00:03.283657 18541 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T12:10:25.822691+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T11:00:00+00:00 PythonOperator 2021-04-18T12:10:26.408308+00:00 2021-04-18T12:10:29.926314+00:00 0:00:03.518006 18540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T12:10:23.574933+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T11:00:00+00:00 TriggerDagRunOperator 2021-04-18T12:10:19.898597+00:00 2021-04-18T12:10:20.423360+00:00 0:00:00.524763 18539 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T12:10:17.492484+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T11:00:00+00:00 TriggerDagRunOperator 2021-04-18T12:10:19.696745+00:00 2021-04-18T12:10:20.121662+00:00 0:00:00.424917 18538 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T12:10:17.492531+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T11:05:00+00:00 EmrJobFlowSensor 2021-04-18T12:08:49.607549+00:00 2021-04-18T12:16:52.074135+00:00 0:08:02.466586 18537 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T12:08:47.386208+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T11:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T12:08:27.456561+00:00 2021-04-18T12:08:29.093005+00:00 0:00:01.636444 18536 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T12:08:25.342606+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T11:05:00+00:00 PythonOperator 2021-04-18T12:08:07.981330+00:00 2021-04-18T12:08:10.889448+00:00 0:00:02.908118 18535 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T12:08:05.380491+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T11:00:00+00:00 EmrJobFlowSensor 2021-04-18T12:01:04.947537+00:00 2021-04-18T12:10:07.911864+00:00 0:09:02.964327 18533 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T12:01:02.586944+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T11:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T12:00:43.166338+00:00 2021-04-18T12:00:44.886855+00:00 0:00:01.720517 18532 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T12:00:40.559681+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T11:00:00+00:00 PythonOperator 2021-04-18T12:00:22.776245+00:00 2021-04-18T12:00:25.712313+00:00 0:00:02.936068 18531 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T12:00:20.499017+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T10:00:00+00:00 EmrJobFlowSensor 2021-04-18T11:12:04.499394+00:00 2021-04-18T11:22:07.525156+00:00 0:10:03.025762 18530 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T11:12:02.168132+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T10:00:00+00:00 EmrJobFlowSensor 2021-04-18T11:11:55.542219+00:00 2021-04-18T11:19:57.940085+00:00 0:08:02.397866 18529 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T11:11:52.160327+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T11:11:42.497483+00:00 2021-04-18T11:11:44.328729+00:00 0:00:01.831246 18528 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T11:11:40.089845+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T11:11:34.437616+00:00 2021-04-18T11:11:36.122050+00:00 0:00:01.684434 18527 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T11:11:32.039908+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T10:00:00+00:00 PythonOperator 2021-04-18T11:11:20.417984+00:00 2021-04-18T11:11:23.615347+00:00 0:00:03.197363 18526 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T11:11:18.025072+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T10:00:00+00:00 PythonOperator 2021-04-18T11:11:12.225475+00:00 2021-04-18T11:11:15.117702+00:00 0:00:02.892227 18525 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T11:11:10.022603+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T10:00:00+00:00 TriggerDagRunOperator 2021-04-18T11:10:56.757932+00:00 2021-04-18T11:10:57.255223+00:00 0:00:00.497291 18524 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T11:10:54.076397+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T10:00:00+00:00 TriggerDagRunOperator 2021-04-18T11:10:56.373061+00:00 2021-04-18T11:10:56.823794+00:00 0:00:00.450733 18523 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T11:10:54.076350+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T10:05:00+00:00 EmrJobFlowSensor 2021-04-18T11:06:17.914495+00:00 2021-04-18T11:15:20.808714+00:00 0:09:02.894219 18522 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T11:06:15.660988+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T10:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T11:05:55.906941+00:00 2021-04-18T11:05:57.566491+00:00 0:00:01.659550 18521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T11:05:53.649620+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T10:05:00+00:00 PythonOperator 2021-04-18T11:05:27.878605+00:00 2021-04-18T11:05:30.730969+00:00 0:00:02.852364 18520 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T11:05:25.513547+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T10:00:00+00:00 EmrJobFlowSensor 2021-04-18T11:00:48.278753+00:00 2021-04-18T11:10:51.194605+00:00 0:10:02.915852 18518 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T11:00:45.950085+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T10:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T11:00:28.128519+00:00 2021-04-18T11:00:29.972560+00:00 0:00:01.844041 18517 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T11:00:25.826551+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T10:00:00+00:00 PythonOperator 2021-04-18T11:00:06.234797+00:00 2021-04-18T11:00:09.670790+00:00 0:00:03.435993 18516 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T11:00:03.804946+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T09:00:00+00:00 EmrJobFlowSensor 2021-04-18T10:13:55.616283+00:00 2021-04-18T10:22:58.363082+00:00 0:09:02.746799 18515 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T10:13:53.263208+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T09:00:00+00:00 EmrJobFlowSensor 2021-04-18T10:13:53.723237+00:00 2021-04-18T10:22:56.178085+00:00 0:09:02.454848 18514 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T10:13:51.262380+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T10:13:33.699267+00:00 2021-04-18T10:13:35.693953+00:00 0:00:01.994686 18513 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T10:13:31.246225+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T10:13:25.623189+00:00 2021-04-18T10:13:27.304439+00:00 0:00:01.681250 18512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T10:13:23.240778+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T09:00:00+00:00 PythonOperator 2021-04-18T10:13:05.599209+00:00 2021-04-18T10:13:08.642528+00:00 0:00:03.043319 18511 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T10:13:03.211108+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T09:00:00+00:00 PythonOperator 2021-04-18T10:12:59.491212+00:00 2021-04-18T10:13:02.666537+00:00 0:00:03.175325 18510 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T10:12:57.172544+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T09:00:00+00:00 TriggerDagRunOperator 2021-04-18T10:12:52.295225+00:00 2021-04-18T10:12:52.757687+00:00 0:00:00.462462 18509 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T10:12:49.166264+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T09:00:00+00:00 TriggerDagRunOperator 2021-04-18T10:12:51.964535+00:00 2021-04-18T10:12:52.475619+00:00 0:00:00.511084 18508 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T10:12:49.166229+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T09:05:00+00:00 EmrJobFlowSensor 2021-04-18T10:05:56.647144+00:00 2021-04-18T10:13:59.236430+00:00 0:08:02.589286 18507 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T10:05:54.462690+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T09:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T10:05:30.687499+00:00 2021-04-18T10:05:32.346652+00:00 0:00:01.659153 18506 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T10:05:28.481706+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T09:05:00+00:00 PythonOperator 2021-04-18T10:05:08.876891+00:00 2021-04-18T10:05:11.989736+00:00 0:00:03.112845 18505 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T10:05:06.419604+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T09:00:00+00:00 EmrJobFlowSensor 2021-04-18T10:03:40.512670+00:00 2021-04-18T10:12:43.178489+00:00 0:09:02.665819 18504 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T10:03:38.235533+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T09:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T10:03:20.578264+00:00 2021-04-18T10:03:22.327031+00:00 0:00:01.748767 18503 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T10:03:18.278988+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T09:00:00+00:00 PythonOperator 2021-04-18T10:02:58.918343+00:00 2021-04-18T10:03:02.035410+00:00 0:00:03.117067 18502 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T10:02:56.119059+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T08:00:00+00:00 EmrJobFlowSensor 2021-04-18T09:13:18.948155+00:00 2021-04-18T09:22:21.699187+00:00 0:09:02.751032 18500 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T09:13:16.482210+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T08:00:00+00:00 EmrJobFlowSensor 2021-04-18T09:13:12.845848+00:00 2021-04-18T09:23:15.666205+00:00 0:10:02.820357 18499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T09:13:10.418772+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T09:12:56.572192+00:00 2021-04-18T09:12:58.269716+00:00 0:00:01.697524 18498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T09:12:54.403005+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T09:12:52.593435+00:00 2021-04-18T09:12:54.291544+00:00 0:00:01.698109 18497 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T09:12:50.410209+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T08:00:00+00:00 PythonOperator 2021-04-18T09:12:36.675178+00:00 2021-04-18T09:12:39.880552+00:00 0:00:03.205374 18496 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T09:12:34.387165+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T08:00:00+00:00 PythonOperator 2021-04-18T09:12:30.870688+00:00 2021-04-18T09:12:34.122521+00:00 0:00:03.251833 18495 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T09:12:28.458090+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T08:00:00+00:00 TriggerDagRunOperator 2021-04-18T09:12:22.888021+00:00 2021-04-18T09:12:23.410130+00:00 0:00:00.522109 18494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T09:12:20.335478+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T08:00:00+00:00 TriggerDagRunOperator 2021-04-18T09:12:22.543472+00:00 2021-04-18T09:12:22.959627+00:00 0:00:00.416155 18493 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T09:12:20.335443+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T08:05:00+00:00 EmrJobFlowSensor 2021-04-18T09:06:12.058485+00:00 2021-04-18T09:14:14.478750+00:00 0:08:02.420265 18492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T09:06:09.862922+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T08:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T09:05:52.016130+00:00 2021-04-18T09:05:53.655244+00:00 0:00:01.639114 18491 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T09:05:49.802466+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T08:05:00+00:00 PythonOperator 2021-04-18T09:05:25.958348+00:00 2021-04-18T09:05:28.816364+00:00 0:00:02.858016 18490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T09:05:23.781720+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T08:00:00+00:00 EmrJobFlowSensor 2021-04-18T09:00:55.711674+00:00 2021-04-18T09:11:58.721335+00:00 0:11:03.009661 18489 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T09:00:53.343524+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T08:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T09:00:33.669622+00:00 2021-04-18T09:00:35.492532+00:00 0:00:01.822910 18488 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T09:00:31.355776+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T08:00:00+00:00 PythonOperator 2021-04-18T09:00:11.913703+00:00 2021-04-18T09:00:14.913087+00:00 0:00:02.999384 18487 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T09:00:09.240890+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T07:00:00+00:00 EmrJobFlowSensor 2021-04-18T08:11:30.769257+00:00 2021-04-18T08:19:33.405993+00:00 0:08:02.636736 18485 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T08:11:28.352622+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T07:00:00+00:00 EmrJobFlowSensor 2021-04-18T08:11:16.522112+00:00 2021-04-18T08:21:19.272805+00:00 0:10:02.750693 18484 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T08:11:14.192392+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T08:11:09.259077+00:00 2021-04-18T08:11:11.068255+00:00 0:00:01.809178 18483 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T08:11:06.186510+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T08:10:50.399397+00:00 2021-04-18T08:10:52.511748+00:00 0:00:02.112351 18482 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T08:10:48.151142+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T07:00:00+00:00 PythonOperator 2021-04-18T08:10:40.652532+00:00 2021-04-18T08:10:43.534926+00:00 0:00:02.882394 18481 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T08:10:38.146169+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T07:00:00+00:00 PythonOperator 2021-04-18T08:10:28.499063+00:00 2021-04-18T08:10:31.713445+00:00 0:00:03.214382 18480 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T08:10:26.134849+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T07:00:00+00:00 TriggerDagRunOperator 2021-04-18T08:10:18.853437+00:00 2021-04-18T08:10:19.431509+00:00 0:00:00.578072 18479 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T08:10:16.125370+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T07:00:00+00:00 TriggerDagRunOperator 2021-04-18T08:10:18.626630+00:00 2021-04-18T08:10:19.058114+00:00 0:00:00.431484 18478 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T08:10:16.125405+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T07:05:00+00:00 EmrJobFlowSensor 2021-04-18T08:06:00.250913+00:00 2021-04-18T08:15:02.939891+00:00 0:09:02.688978 18477 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T08:05:57.757361+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T07:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T08:05:37.891026+00:00 2021-04-18T08:05:39.611798+00:00 0:00:01.720772 18476 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T08:05:35.721936+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T07:05:00+00:00 PythonOperator 2021-04-18T08:05:16.193818+00:00 2021-04-18T08:05:19.234913+00:00 0:00:03.041095 18475 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T08:05:13.755847+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T07:00:00+00:00 EmrJobFlowSensor 2021-04-18T08:00:54.005264+00:00 2021-04-18T08:09:56.754645+00:00 0:09:02.749381 18474 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T08:00:51.240766+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T07:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T08:00:33.307159+00:00 2021-04-18T08:00:35.060512+00:00 0:00:01.753353 18473 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T08:00:31.116325+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T07:00:00+00:00 PythonOperator 2021-04-18T08:00:11.450114+00:00 2021-04-18T08:00:14.504700+00:00 0:00:03.054586 18472 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T08:00:09.096987+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T06:00:00+00:00 EmrJobFlowSensor 2021-04-18T07:12:25.539558+00:00 2021-04-18T07:21:28.361416+00:00 0:09:02.821858 18470 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T07:12:23.304925+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T06:00:00+00:00 EmrJobFlowSensor 2021-04-18T07:12:19.531460+00:00 2021-04-18T07:22:22.224593+00:00 0:10:02.693133 18469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T07:12:17.300380+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T07:12:03.584303+00:00 2021-04-18T07:12:05.418519+00:00 0:00:01.834216 18468 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T07:12:01.287622+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T07:11:57.783175+00:00 2021-04-18T07:11:59.441347+00:00 0:00:01.658172 18467 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T07:11:55.357363+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T06:00:00+00:00 PythonOperator 2021-04-18T07:11:41.585051+00:00 2021-04-18T07:11:44.822927+00:00 0:00:03.237876 18466 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T07:11:39.248047+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T06:00:00+00:00 PythonOperator 2021-04-18T07:11:37.322820+00:00 2021-04-18T07:11:40.322531+00:00 0:00:02.999711 18465 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T07:11:35.143568+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T06:00:00+00:00 TriggerDagRunOperator 2021-04-18T07:11:19.419248+00:00 2021-04-18T07:11:19.830351+00:00 0:00:00.411103 18464 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T07:11:17.069014+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T06:00:00+00:00 TriggerDagRunOperator 2021-04-18T07:11:19.414264+00:00 2021-04-18T07:11:19.950679+00:00 0:00:00.536415 18463 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T07:11:17.069044+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T06:05:00+00:00 EmrJobFlowSensor 2021-04-18T07:05:54.794512+00:00 2021-04-18T07:14:57.471084+00:00 0:09:02.676572 18462 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T07:05:52.501835+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T06:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T07:05:32.971780+00:00 2021-04-18T07:05:34.621014+00:00 0:00:01.649234 18461 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T07:05:30.540854+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T06:05:00+00:00 PythonOperator 2021-04-18T07:05:10.587369+00:00 2021-04-18T07:05:13.481761+00:00 0:00:02.894392 18460 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T07:05:08.391118+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2021-04-18T06:00:00+00:00 EmrJobFlowSensor 2021-04-18T07:00:56.858824+00:00 2021-04-18T07:10:59.604402+00:00 0:10:02.745578 18459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T07:00:53.861141+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2021-04-18T06:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T07:00:36.149648+00:00 2021-04-18T07:00:37.928993+00:00 0:00:01.779345 18458 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2021-04-18T07:00:33.791715+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2021-04-18T06:00:00+00:00 PythonOperator 2021-04-18T07:00:14.299653+00:00 2021-04-18T07:00:17.256891+00:00 0:00:02.957238 18457 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2021-04-18T07:00:11.746894+00:00 2 default_pool
success booking-processing-job_v002 check_cluster_status 2021-04-18T05:00:00+00:00 EmrJobFlowSensor 2021-04-18T06:11:21.417602+00:00 2021-04-18T06:21:24.311658+00:00 0:10:02.894056 18455 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T06:11:19.149812+00:00 2 default_pool
success campaign-history-job_v002 check_cluster_status 2021-04-18T05:00:00+00:00 EmrJobFlowSensor 2021-04-18T06:11:09.618017+00:00 2021-04-18T06:19:12.047872+00:00 0:08:02.429855 18454 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T06:11:07.144494+00:00 2 default_pool
success booking-processing-job_v002 create_cluster_and_add_emr_steps 2021-04-18T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T06:10:59.762348+00:00 2021-04-18T06:11:01.570704+00:00 0:00:01.808356 18453 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T06:10:57.150374+00:00 2 default_pool
success campaign-history-job_v002 create_cluster_and_add_emr_steps 2021-04-18T05:00:00+00:00 EmrCreateJobFlowOperator 2021-04-18T06:10:45.404626+00:00 2021-04-18T06:10:47.519014+00:00 0:00:02.114388 18452 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T06:10:43.143754+00:00 2 default_pool
success booking-processing-job_v002 create_emr_steps 2021-04-18T05:00:00+00:00 PythonOperator 2021-04-18T06:10:37.624522+00:00 2021-04-18T06:10:41.177710+00:00 0:00:03.553188 18451 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T06:10:35.041823+00:00 2 default_pool
success campaign-history-job_v002 create_emr_steps 2021-04-18T05:00:00+00:00 PythonOperator 2021-04-18T06:10:25.382814+00:00 2021-04-18T06:10:28.316825+00:00 0:00:02.934011 18450 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T06:10:23.063885+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2021-04-18T05:00:00+00:00 TriggerDagRunOperator 2021-04-18T06:10:19.511768+00:00 2021-04-18T06:10:20.047881+00:00 0:00:00.536113 18449 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T06:10:17.047557+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2021-04-18T05:00:00+00:00 TriggerDagRunOperator 2021-04-18T06:10:19.367692+00:00 2021-04-18T06:10:19.800928+00:00 0:00:00.433236 18448 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T06:10:17.047509+00:00 2 default_pool
success vc-asset-import_v002 check_cluster_status 2021-04-18T05:05:00+00:00 EmrJobFlowSensor 2021-04-18T06:05:54.810171+00:00 2021-04-18T06:13:57.378499+00:00 0:08:02.568328 18447 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2021-04-18T06:05:52.391639+00:00 2 default_pool
success vc-asset-import_v002 create_cluster_and_add_emr_steps 2021-04-18T05:05:00+00:00 EmrCreateJobFlowOperator 2021-04-18T06:05:32.469005+00:00 2021-04-18T06:05:34.081152+00:00 0:00:01.612147 18446 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 2 default 2021-04-18T06:05:30.161094+00:00 2 default_pool
success vc-asset-import_v002 create_emr_steps 2021-04-18T05:05:00+00:00 PythonOperator 2021-04-18T06:05:10.301697+00:00 2021-04-18T06:05:13.710181+00:00 0:00:03.408484 18445 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2021-04-18T06:05:08.088154+00:00 2 default_pool