Task Instances

Reset Filters
  State Dag Id Task Id Execution Date Operator Start Date End Date Duration Job Id Hostname Unixname Priority Weight Queue Queued Dttm Try Number Pool Log Url
success campaign-flow-job_v002 check_cluster_status 2023-03-05T13:00:00+00:00 EmrJobFlowSensor 2023-03-05T14:02:17.769993+00:00 2023-03-05T14:12:19.433480+00:00 0:10:01.663487 348839 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T14:02:15.561877+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T13:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T14:01:55.757929+00:00 2023-03-05T14:01:56.695595+00:00 0:00:00.937666 348837 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T14:01:53.542933+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T13:00:00+00:00 PythonOperator 2023-03-05T14:01:36.239128+00:00 2023-03-05T14:01:40.146701+00:00 0:00:03.907573 348835 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T14:01:33.624298+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T12:00:00+00:00 TriggerDagRunOperator 2023-03-05T13:17:11.238008+00:00 2023-03-05T13:17:11.741216+00:00 0:00:00.503208 348828 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T13:17:08.076043+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T12:00:00+00:00 TriggerDagRunOperator 2023-03-05T13:17:10.978891+00:00 2023-03-05T13:17:11.576070+00:00 0:00:00.597179 348827 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T13:17:08.076012+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T12:00:00+00:00 EmrJobFlowSensor 2023-03-05T13:08:04.358574+00:00 2023-03-05T13:17:06.010552+00:00 0:09:01.651978 348824 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T13:08:02.062860+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T12:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T13:07:44.415536+00:00 2023-03-05T13:07:46.095722+00:00 0:00:01.680186 348821 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T13:07:40.045901+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T12:00:00+00:00 PythonOperator 2023-03-05T13:07:24.213391+00:00 2023-03-05T13:07:28.616879+00:00 0:00:04.403488 348818 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T13:07:20.023862+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T11:00:00+00:00 TriggerDagRunOperator 2023-03-05T12:10:53.634664+00:00 2023-03-05T12:10:54.159945+00:00 0:00:00.525281 348806 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T12:10:51.147226+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T11:00:00+00:00 TriggerDagRunOperator 2023-03-05T12:10:53.508659+00:00 2023-03-05T12:10:53.990446+00:00 0:00:00.481787 348805 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T12:10:51.147197+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T11:00:00+00:00 EmrJobFlowSensor 2023-03-05T12:02:27.710100+00:00 2023-03-05T12:10:29.335526+00:00 0:08:01.625426 348797 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T12:02:24.761014+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T11:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T12:00:33.302778+00:00 2023-03-05T12:00:34.139707+00:00 0:00:00.836929 348795 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T12:00:30.784304+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T11:00:00+00:00 PythonOperator 2023-03-05T12:00:13.655935+00:00 2023-03-05T12:00:16.872290+00:00 0:00:03.216355 348793 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T12:00:10.769205+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T10:00:00+00:00 TriggerDagRunOperator 2023-03-05T11:11:33.677138+00:00 2023-03-05T11:11:34.194573+00:00 0:00:00.517435 348787 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T11:11:31.132335+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T10:00:00+00:00 TriggerDagRunOperator 2023-03-05T11:11:33.640540+00:00 2023-03-05T11:11:34.129025+00:00 0:00:00.488485 348786 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T11:11:31.132307+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T10:00:00+00:00 EmrJobFlowSensor 2023-03-05T11:01:13.060734+00:00 2023-03-05T11:11:14.768476+00:00 0:10:01.707742 348779 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T11:01:10.833145+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T10:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T11:00:53.044459+00:00 2023-03-05T11:00:53.887058+00:00 0:00:00.842599 348777 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T11:00:50.815356+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T10:00:00+00:00 PythonOperator 2023-03-05T11:00:31.465851+00:00 2023-03-05T11:00:34.836653+00:00 0:00:03.370802 348775 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T11:00:28.793187+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T09:00:00+00:00 TriggerDagRunOperator 2023-03-05T10:27:31.764793+00:00 2023-03-05T10:27:32.258831+00:00 0:00:00.494038 348768 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T10:27:28.860618+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T09:00:00+00:00 TriggerDagRunOperator 2023-03-05T10:27:31.561835+00:00 2023-03-05T10:27:32.057739+00:00 0:00:00.495904 348767 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T10:27:28.860590+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T09:00:00+00:00 EmrJobFlowSensor 2023-03-05T10:14:23.731854+00:00 2023-03-05T10:24:25.521750+00:00 0:10:01.789896 348762 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T10:14:21.490398+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T09:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T10:14:01.709579+00:00 2023-03-05T10:14:03.103848+00:00 0:00:01.394269 348759 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T10:13:59.438813+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T09:00:00+00:00 PythonOperator 2023-03-05T10:13:41.975683+00:00 2023-03-05T10:13:48.918853+00:00 0:00:06.943170 348756 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T10:13:39.423365+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T08:00:00+00:00 TriggerDagRunOperator 2023-03-05T09:13:56.562336+00:00 2023-03-05T09:13:57.062456+00:00 0:00:00.500120 348749 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T09:13:53.619329+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T08:00:00+00:00 TriggerDagRunOperator 2023-03-05T09:13:56.313330+00:00 2023-03-05T09:13:56.779732+00:00 0:00:00.466402 348748 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T09:13:53.619360+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T08:00:00+00:00 EmrJobFlowSensor 2023-03-05T09:01:06.628032+00:00 2023-03-05T09:11:08.887427+00:00 0:10:02.259395 348741 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T09:01:04.209349+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T08:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T09:00:46.652741+00:00 2023-03-05T09:00:47.508152+00:00 0:00:00.855411 348740 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T09:00:44.238471+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T08:00:00+00:00 PythonOperator 2023-03-05T09:00:24.699394+00:00 2023-03-05T09:00:28.841788+00:00 0:00:04.142394 348737 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T09:00:22.213156+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T07:00:00+00:00 TriggerDagRunOperator 2023-03-05T08:23:58.030464+00:00 2023-03-05T08:23:58.535173+00:00 0:00:00.504709 348729 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T08:23:54.988258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T07:00:00+00:00 TriggerDagRunOperator 2023-03-05T08:23:57.848823+00:00 2023-03-05T08:23:58.311497+00:00 0:00:00.462674 348728 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T08:23:54.988216+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T07:00:00+00:00 EmrJobFlowSensor 2023-03-05T08:04:52.102097+00:00 2023-03-05T08:13:53.963838+00:00 0:09:01.861741 348721 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T08:04:49.744415+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T07:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T08:04:30.265286+00:00 2023-03-05T08:04:31.289877+00:00 0:00:01.024591 348719 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T08:04:27.693785+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T07:00:00+00:00 PythonOperator 2023-03-05T08:04:08.147419+00:00 2023-03-05T08:04:12.014428+00:00 0:00:03.867009 348717 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T08:04:05.675174+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T06:00:00+00:00 TriggerDagRunOperator 2023-03-05T07:30:23.431162+00:00 2023-03-05T07:30:23.933369+00:00 0:00:00.502207 348711 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T07:30:20.490680+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T06:00:00+00:00 TriggerDagRunOperator 2023-03-05T07:30:23.275975+00:00 2023-03-05T07:30:23.744979+00:00 0:00:00.469004 348710 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T07:30:20.490638+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T06:00:00+00:00 EmrJobFlowSensor 2023-03-05T07:08:36.720558+00:00 2023-03-05T07:18:38.955755+00:00 0:10:02.235197 348705 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T07:08:34.164285+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T06:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T07:08:16.330271+00:00 2023-03-05T07:08:17.228913+00:00 0:00:00.898642 348702 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T07:08:14.152313+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T06:00:00+00:00 PythonOperator 2023-03-05T07:07:54.724269+00:00 2023-03-05T07:07:58.631577+00:00 0:00:03.907308 348699 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T07:07:52.174352+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T05:00:00+00:00 TriggerDagRunOperator 2023-03-05T06:31:08.064539+00:00 2023-03-05T06:31:08.533059+00:00 0:00:00.468520 348693 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T06:31:05.411258+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T05:00:00+00:00 TriggerDagRunOperator 2023-03-05T06:31:07.933808+00:00 2023-03-05T06:31:08.460949+00:00 0:00:00.527141 348692 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T06:31:05.411213+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T05:00:00+00:00 EmrJobFlowSensor 2023-03-05T06:20:48.346643+00:00 2023-03-05T06:30:50.117808+00:00 0:10:01.771165 348688 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T06:20:46.011961+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T05:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T06:20:29.012483+00:00 2023-03-05T06:20:29.857400+00:00 0:00:00.844917 348685 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T06:20:25.975085+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T05:00:00+00:00 PythonOperator 2023-03-05T06:20:06.329995+00:00 2023-03-05T06:20:09.514793+00:00 0:00:03.184798 348682 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T06:20:03.932726+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T04:00:00+00:00 TriggerDagRunOperator 2023-03-05T05:46:57.797694+00:00 2023-03-05T05:46:58.273810+00:00 0:00:00.476116 348676 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T05:46:55.412715+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T04:00:00+00:00 TriggerDagRunOperator 2023-03-05T05:46:57.733504+00:00 2023-03-05T05:46:58.226416+00:00 0:00:00.492912 348675 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T05:46:55.412744+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T04:00:00+00:00 EmrJobFlowSensor 2023-03-05T05:00:55.353262+00:00 2023-03-05T05:10:57.082549+00:00 0:10:01.729287 348668 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T05:00:53.146609+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T04:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T05:00:34.624812+00:00 2023-03-05T05:00:35.503905+00:00 0:00:00.879093 348666 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T05:00:31.289661+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T04:00:00+00:00 PythonOperator 2023-03-05T05:00:13.474031+00:00 2023-03-05T05:00:16.563048+00:00 0:00:03.089017 348664 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T05:00:11.116474+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T03:00:00+00:00 TriggerDagRunOperator 2023-03-05T04:18:12.197653+00:00 2023-03-05T04:18:12.682428+00:00 0:00:00.484775 348655 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T04:18:09.523581+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T03:00:00+00:00 TriggerDagRunOperator 2023-03-05T04:18:12.028619+00:00 2023-03-05T04:18:12.504610+00:00 0:00:00.475991 348654 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T04:18:09.523551+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T03:00:00+00:00 EmrJobFlowSensor 2023-03-05T04:08:58.562148+00:00 2023-03-05T04:18:00.210783+00:00 0:09:01.648635 348650 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T04:08:56.379306+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T03:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T04:08:38.640546+00:00 2023-03-05T04:08:39.567254+00:00 0:00:00.926708 348647 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T04:08:36.363291+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T03:00:00+00:00 PythonOperator 2023-03-05T04:08:16.655181+00:00 2023-03-05T04:08:19.599261+00:00 0:00:02.944080 348644 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T04:08:14.350126+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T02:00:00+00:00 TriggerDagRunOperator 2023-03-05T03:11:10.197965+00:00 2023-03-05T03:11:10.693946+00:00 0:00:00.495981 348634 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T03:11:07.902229+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T02:00:00+00:00 TriggerDagRunOperator 2023-03-05T03:11:10.164221+00:00 2023-03-05T03:11:10.697925+00:00 0:00:00.533704 348633 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T03:11:07.902196+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T02:00:00+00:00 EmrJobFlowSensor 2023-03-05T03:00:48.159863+00:00 2023-03-05T03:10:49.997355+00:00 0:10:01.837492 348626 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T03:00:45.815440+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T02:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T03:00:28.177269+00:00 2023-03-05T03:00:28.978737+00:00 0:00:00.801468 348624 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T03:00:25.804660+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T02:00:00+00:00 PythonOperator 2023-03-05T03:00:06.524864+00:00 2023-03-05T03:00:09.720022+00:00 0:00:03.195158 348622 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T03:00:03.790800+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T01:00:00+00:00 TriggerDagRunOperator 2023-03-05T02:11:26.811803+00:00 2023-03-05T02:11:27.327133+00:00 0:00:00.515330 348611 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T02:11:24.372333+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T01:00:00+00:00 TriggerDagRunOperator 2023-03-05T02:11:26.631094+00:00 2023-03-05T02:11:27.106803+00:00 0:00:00.475709 348610 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T02:11:24.372382+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T01:00:00+00:00 EmrJobFlowSensor 2023-03-05T02:01:07.223029+00:00 2023-03-05T02:11:08.896908+00:00 0:10:01.673879 348606 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T02:01:04.940737+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T01:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T02:00:45.352849+00:00 2023-03-05T02:00:46.166793+00:00 0:00:00.813944 348604 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T02:00:42.887069+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T01:00:00+00:00 PythonOperator 2023-03-05T02:00:23.253120+00:00 2023-03-05T02:00:27.149824+00:00 0:00:03.896704 348602 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T02:00:20.654737+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-05T00:00:00+00:00 TriggerDagRunOperator 2023-03-05T01:11:14.866206+00:00 2023-03-05T01:11:15.417445+00:00 0:00:00.551239 348587 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T01:11:12.186600+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-05T00:00:00+00:00 TriggerDagRunOperator 2023-03-05T01:11:14.634087+00:00 2023-03-05T01:11:15.253144+00:00 0:00:00.619057 348586 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T01:11:12.186651+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-05T00:00:00+00:00 EmrJobFlowSensor 2023-03-05T01:01:00.064171+00:00 2023-03-05T01:11:02.236271+00:00 0:10:02.172100 348579 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T01:00:57.448624+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-05T00:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T01:00:37.804695+00:00 2023-03-05T01:00:38.655504+00:00 0:00:00.850809 348577 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T01:00:35.496589+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-05T00:00:00+00:00 PythonOperator 2023-03-05T01:00:18.300767+00:00 2023-03-05T01:00:21.481070+00:00 0:00:03.180303 348575 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T01:00:15.416000+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-04T23:00:00+00:00 TriggerDagRunOperator 2023-03-05T00:12:14.746308+00:00 2023-03-05T00:12:15.552921+00:00 0:00:00.806613 348567 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T00:12:11.738326+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-04T23:00:00+00:00 TriggerDagRunOperator 2023-03-05T00:12:14.252196+00:00 2023-03-05T00:12:15.184079+00:00 0:00:00.931883 348566 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-05T00:12:11.738361+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-04T23:00:00+00:00 EmrJobFlowSensor 2023-03-05T00:02:51.492212+00:00 2023-03-05T00:11:53.176614+00:00 0:09:01.684402 348560 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-05T00:02:49.274626+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-04T23:00:00+00:00 EmrCreateJobFlowOperator 2023-03-05T00:02:29.555247+00:00 2023-03-05T00:02:30.437636+00:00 0:00:00.882389 348558 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-05T00:02:27.255919+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-04T23:00:00+00:00 PythonOperator 2023-03-05T00:02:09.735782+00:00 2023-03-05T00:02:13.702934+00:00 0:00:03.967152 348556 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-05T00:02:07.235485+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-04T22:00:00+00:00 TriggerDagRunOperator 2023-03-04T23:14:05.264737+00:00 2023-03-04T23:14:05.745956+00:00 0:00:00.481219 348547 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T23:14:02.044494+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-04T22:00:00+00:00 TriggerDagRunOperator 2023-03-04T23:14:04.706262+00:00 2023-03-04T23:14:05.212710+00:00 0:00:00.506448 348546 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T23:14:02.044466+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-04T22:00:00+00:00 EmrJobFlowSensor 2023-03-04T23:01:51.994846+00:00 2023-03-04T23:11:53.608041+00:00 0:10:01.613195 348540 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-04T23:01:49.698765+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-04T22:00:00+00:00 EmrCreateJobFlowOperator 2023-03-04T23:01:31.750897+00:00 2023-03-04T23:01:32.814384+00:00 0:00:01.063487 348537 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-04T23:01:29.497569+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-04T22:00:00+00:00 PythonOperator 2023-03-04T23:01:09.923852+00:00 2023-03-04T23:01:13.096471+00:00 0:00:03.172619 348534 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-04T23:01:07.478176+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-04T21:00:00+00:00 TriggerDagRunOperator 2023-03-04T22:13:33.926795+00:00 2023-03-04T22:13:34.411908+00:00 0:00:00.485113 348522 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T22:13:31.090865+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-04T21:00:00+00:00 TriggerDagRunOperator 2023-03-04T22:13:33.705625+00:00 2023-03-04T22:13:34.171366+00:00 0:00:00.465741 348521 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T22:13:31.090834+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-04T21:00:00+00:00 EmrJobFlowSensor 2023-03-04T22:03:24.381463+00:00 2023-03-04T22:13:26.221731+00:00 0:10:01.840268 348514 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-04T22:03:22.020969+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-04T21:00:00+00:00 EmrCreateJobFlowOperator 2023-03-04T22:03:04.223014+00:00 2023-03-04T22:03:05.027274+00:00 0:00:00.804260 348512 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-04T22:03:01.999713+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-04T21:00:00+00:00 PythonOperator 2023-03-04T22:02:42.898876+00:00 2023-03-04T22:02:46.648061+00:00 0:00:03.749185 348510 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-04T22:02:39.928940+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-04T20:00:00+00:00 TriggerDagRunOperator 2023-03-04T21:15:26.414543+00:00 2023-03-04T21:15:26.910112+00:00 0:00:00.495569 348499 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T21:15:23.706374+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-04T20:00:00+00:00 TriggerDagRunOperator 2023-03-04T21:15:26.186802+00:00 2023-03-04T21:15:26.653681+00:00 0:00:00.466879 348498 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T21:15:23.706403+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-04T20:00:00+00:00 EmrJobFlowSensor 2023-03-04T21:00:50.724689+00:00 2023-03-04T21:10:52.566215+00:00 0:10:01.841526 348494 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-04T21:00:48.129622+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-04T20:00:00+00:00 EmrCreateJobFlowOperator 2023-03-04T21:00:28.504802+00:00 2023-03-04T21:00:29.356680+00:00 0:00:00.851878 348492 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-04T21:00:26.117840+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-04T20:00:00+00:00 PythonOperator 2023-03-04T21:00:06.674669+00:00 2023-03-04T21:00:10.690744+00:00 0:00:04.016075 348490 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-04T21:00:04.112298+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-04T19:00:00+00:00 TriggerDagRunOperator 2023-03-04T20:10:07.423219+00:00 2023-03-04T20:10:07.939337+00:00 0:00:00.516118 348480 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T20:10:05.102904+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-04T19:00:00+00:00 TriggerDagRunOperator 2023-03-04T20:10:07.338019+00:00 2023-03-04T20:10:07.791904+00:00 0:00:00.453885 348479 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T20:10:05.102934+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-04T19:00:00+00:00 EmrJobFlowSensor 2023-03-04T20:00:58.854727+00:00 2023-03-04T20:10:00.577544+00:00 0:09:01.722817 348473 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-04T20:00:56.591950+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-04T19:00:00+00:00 EmrCreateJobFlowOperator 2023-03-04T20:00:38.714141+00:00 2023-03-04T20:00:39.522007+00:00 0:00:00.807866 348471 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-04T20:00:36.465922+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-04T19:00:00+00:00 PythonOperator 2023-03-04T20:00:16.831561+00:00 2023-03-04T20:00:20.787699+00:00 0:00:03.956138 348469 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-04T20:00:14.519640+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-04T18:00:00+00:00 TriggerDagRunOperator 2023-03-04T19:17:38.441378+00:00 2023-03-04T19:17:38.970918+00:00 0:00:00.529540 348459 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T19:17:35.368961+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-04T18:00:00+00:00 TriggerDagRunOperator 2023-03-04T19:17:38.212908+00:00 2023-03-04T19:17:38.696706+00:00 0:00:00.483798 348458 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T19:17:35.368924+00:00 2 default_pool
success campaign-flow-job_v002 check_cluster_status 2023-03-04T18:00:00+00:00 EmrJobFlowSensor 2023-03-04T19:01:03.979552+00:00 2023-03-04T19:11:05.805379+00:00 0:10:01.825827 348451 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 3 default 2023-03-04T19:01:01.394723+00:00 2 default_pool
success campaign-flow-job_v002 create_cluster_and_add_emr_steps 2023-03-04T18:00:00+00:00 EmrCreateJobFlowOperator 2023-03-04T19:00:42.530138+00:00 2023-03-04T19:00:43.552566+00:00 0:00:01.022428 348449 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 4 default 2023-03-04T19:00:39.309487+00:00 2 default_pool
success campaign-flow-job_v002 create_emr_steps 2023-03-04T18:00:00+00:00 PythonOperator 2023-03-04T19:00:19.451528+00:00 2023-03-04T19:00:23.388467+00:00 0:00:03.936939 348447 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 5 default 2023-03-04T19:00:17.227905+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_campaign-history-job_v002 2023-03-04T17:00:00+00:00 TriggerDagRunOperator 2023-03-04T18:17:40.457992+00:00 2023-03-04T18:17:41.114339+00:00 0:00:00.656347 348439 airflow-worker-1.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T18:17:37.481022+00:00 2 default_pool
success campaign-flow-job_v002 trigger_dagrun_booking-processing-job_v002 2023-03-04T17:00:00+00:00 TriggerDagRunOperator 2023-03-04T18:17:40.460168+00:00 2023-03-04T18:17:40.971310+00:00 0:00:00.511142 348438 airflow-worker-0.airflow-worker.bigdata.svc.cluster.local airflow 1 default 2023-03-04T18:17:37.480990+00:00 2 default_pool