def main()

in python-batch/cuda_pubsub/pull_fifo_id.py [0:0]

• 11 lines of code
• 4 McCabe index (conditional complexity)

def main(argv):
  subscription_id = "sub-" + FLAGS.job_id

  subscriber = pubsub_v1.SubscriberClient()
  subscription_path = subscriber.subscription_path(FLAGS.project_id, subscription_id)
  pull_response= subscriber.pull(subscription=subscription_path, max_messages=1)

  if FLAGS.debug: print(pull_response.received_messages)

  for msg in pull_response.received_messages:
      message = msg.message.data.decode('utf-8')
      # do your thing
      print(message)
      if FLAGS.debug: print(msg.ack_id)
      subscriber.acknowledge(subscription=subscription_path, ack_ids=[msg.ack_id])