diff --git a/tests/automatic/consumer/consumer_api_python/consumer_api.py b/tests/automatic/consumer/consumer_api_python/consumer_api.py index 820b59fafc7615ae26df0c533bc7f5de9b4a5aa5..7533e3584b8246f2edfa9ef2cd7eeae4cbf668eb 100644 --- a/tests/automatic/consumer/consumer_api_python/consumer_api.py +++ b/tests/automatic/consumer/consumer_api_python/consumer_api.py @@ -234,6 +234,7 @@ def check_single(broker, group_id): broker = asapo_consumer.create_server_broker("bla", path, True, beamtime, "", token, 60000) t = Thread(target = long_call, args = (broker,) ) t.start() + time.sleep(1) broker.interrupt_current_operation() t.join() assert_eq(thread_res, 2, "long call res")