from CommonCode import kwq
publish = kwq.producer.send
topic = kwq.TOPICS.videos_to_score_detection
cons = kwq.create_consumer()

# %%
cons.subscribe([topic])

# %%
if True:
    out = cons.poll()