The scheduler does not appear to be running. Last heartbeat was received .

The DAGs list may not update, and new tasks will not be scheduled.

DAG: booking-by-hour-model-transform_v002

schedule: 30 1 * * *

Task Instance: create_emr_steps

Rendered Template

templates_dict
None
op_args
[]
op_kwargs
{'cluster-name': 'booking-by-hour-model-transform',
 'core-instance-capacity': 5,
 'core-instance-types': 'm5.2xlarge,m5.4xlarge',
 'dag-id': 'booking-by-hour-model-transform_v002',
 'ebs-volume-size': '50',
 'emr-steps': '[\n'
              '    {\n'
              '       "step-name": "BookingByHour-ModelTransform",\n'
              '        "config-json": [\n'
              '          {"spark.driver.memory":"20g"}\n'
              '        ],\n'
              '        "main-class": '
              '"com.viooh.transform.BookingModelTransform",\n'
              '        "group-id": "uk/co/viooh",\n'
              '        "artifact": "pandora-model-transform",\n'
              '        "files": '
              '"s3://viooh-spark-artifacts-lab-cn/metrics/batch-job-metrics/0.0.0/job.conf,s3://viooh-spark-artifacts-lab-cn/metrics/batch-job-metrics/0.0.0/job.yaml"\n'
              '    }\n'
              ']',
 'emr-version': 'emr-6.14.0',
 'master-instance-types': 'm5.xlarge,m5.4xlarge',
 'schedule_interval': '30 1 * * *',
 'task-instance-capacity': 0,
 'task-instance-types': 'm5.2xlarge,m5.4xlarge',
 'trigger_dags': []}