Merge pull request #3 from jwplayer/bug-fix-cluster-logging

BUG fix logging of cluster id
jwplayer · Jan 24, 2017 · d58c87c · d58c87c
2 parents 7d7a83f + 066f435
commit d58c87c
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,