Commit 46d6376b authored by Lionel Walter's avatar Lionel Walter

Use snake case instead of camel case

parent 3f31e332
Pipeline #10126 passed with stages
in 9 minutes and 45 seconds
......@@ -60,13 +60,13 @@ class JobReport(Resource):
try: # read job-reporting messages from kafka
topic_partition = TopicPartition(topic=topic_name, partition=0)
jobMessages = consumer.poll(1000, 1000)
job_messages = consumer.poll(1000, 1000)
processed = succeeded = 0
if jobMessages:
for jobMessage in jobMessages[topic_partition]:
msgValue = jobMessage.value
if msgValue['status'] == 'FAILURE':
report = report + msgValue['id'] + ": " + msgValue['message'] + "\n"
if job_messages:
for jobMessage in job_messages[topic_partition]:
msg_value = jobMessage.value
if msg_value['status'] == 'FAILURE':
report = report + msg_value['id'] + ": " + msg_value['message'] + "\n"
else:
succeeded = succeeded + 1
processed = processed + 1
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment