BUG fix logging of cluster

jwplayer · Jan 24, 2017 · 066f435 · 066f435
1 parent 7d7a83f
commit 066f435
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sparksteps/__main__.py b/sparksteps/__main__.py
@@ -121,7 +121,7 @@ def main():
         cluster_config = cluster.emr_config(**args_dict)
         response = client.run_job_flow(**cluster_config)
         cluster_id = response['JobFlowId']
-        logger.info("Cluster ID: ", cluster_id)
+        logger.info("Cluster ID: %s", cluster_id)
 
     emr_steps = steps.setup_steps(s3,
                                   args.s3_bucket,