Rendered Template
templates_dict
None
op_args
[]
op_kwargs
{'cluster-name': 'booking-processing-job',
'core-instance-capacity': 3,
'core-instance-types': 'm5.xlarge,m5.2xlarge',
'dag-id': 'booking-processing-job_v002',
'ebs-volume-size': '50',
'emr-steps': '[\n'
' {\n'
' "step-name": "CampaignExtractor",\n'
' "config-json": [\n'
' {"spark.driver.memory":"9g"}\n'
' ],\n'
' "main-class": '
'"com.viooh.campaignextractor.CampaignExtractorMain",\n'
' "group-id":"com/viooh/campaignextractor",\n'
' "artifact": "campaign-extractor",\n'
' "jars": "/usr/lib/spark/external/lib/spark-avro.jar"\n'
' },\n'
' {\n'
' "step-name": "CampaignProcessingJob",\n'
' "config-json": [\n'
' {"spark.driver.memory":"9g"}\n'
' ],\n'
' "main-class": "com.viooh.CampaignProcessingMain",\n'
' "artifact": "campaign-processing-job"\n'
' },\n'
' {\n'
' "step-name": "CampaignDeltaJob",\n'
' "config-json": [\n'
' {"spark.driver.memory":"9g"}\n'
' ],\n'
' "main-class": '
'"com.viooh.booking.delta.CampaignDeltaMain",\n'
' "artifact": "pandora-campaign-delta",\n'
' "enable-custom-metrics" : "True"\n'
' }\n'
']',
'job-type': 'batch',
'master-instance-types': 'm5.xlarge,m5.2xlarge',
'schedule_interval': '0 */1 * * *',
'task-instance-capacity': 0,
'task-instance-types': 'm5.xlarge,m5.2xlarge',
'trigger_dags': []}