def publish_event()

in cqrs/services/event-publisher/main.py [0:0]

• 32 lines of code
• 3 McCabe index (conditional complexity)

def publish_event():
    futures = {}
    def get_callback(future, result):
        def callback(future):
            event_id = result['event_id']
            try:
                future.result()
                result['published'] = True
                ds_client.put(result)
            except:
                print('Failed to publish an event {}: {}'.format(event_id, future.exception()),
                        file=sys.stderr)
            finally:
                futures.pop(event_id)
        return callback

    query = ds_client.query(kind='Event')
    query.add_filter('published', '=', False)
    query.order = ['timestamp']
    for result in query.fetch():
        publisher = pubsub_v1.PublisherClient()
        topic_name = 'projects/{}/topics/{}'.format(
            os.getenv('PROJECT_ID'), result['topic'])
        event_id = result['event_id']
        event_type = result['type']
        body = result['body'].encode("utf-8")

        future = publisher.publish(topic_name, body,
                    event_id=event_id, event_type=event_type)
        futures[event_id] = future
        future.add_done_callback(get_callback(future, result))

    while futures:
        time.sleep(5)

    return 'Finished.', 200