diff --git a/tests/automatic/full_chain/send_recv_streams_python/send_recv_streams.py b/tests/automatic/full_chain/send_recv_streams_python/send_recv_streams.py index d603ab01f57ab6136aa096ae35fac4dd2c299aca..85bf3208195a0c32cd006cf6745eb874bc2c3e4a 100644 --- a/tests/automatic/full_chain/send_recv_streams_python/send_recv_streams.py +++ b/tests/automatic/full_chain/send_recv_streams_python/send_recv_streams.py @@ -25,8 +25,8 @@ def callback(header,err): source, beamtime, token = sys.argv[1:] -consumer = asapo_consumer.create_consumer(source,".",True,"auto","Consumer",beamtime,"",token,timeout) -producer = asapo_producer.create_producer(source,'processed',"auto","Producer",beamtime,'auto', "", token, 1, 600000) +consumer = asapo_consumer.create_consumer(source,".",True,beamtime,"",token,timeout,"auto","Consumer") +producer = asapo_producer.create_producer(source,'processed',beamtime,'auto', "", token, 1, 600000,"auto","Producer") producer.set_log_level("debug") group_id = consumer.generate_group_id()