Commit 2ed7921e authored by Tim Schoof's avatar Tim Schoof
Browse files

Increase timeout default value

parent 81e399ed
Pipeline #28 failed with stages
in 12 minutes and 44 seconds
...@@ -23,6 +23,7 @@ def create_broker(source, path, beamtime, stream, token, timeout): ...@@ -23,6 +23,7 @@ def create_broker(source, path, beamtime, stream, token, timeout):
return broker return broker
# TODO: Ensure also that indices are consecutive or start at 0
@Configurable @Configurable
class AsapoReceiver: class AsapoReceiver:
""" """
...@@ -45,7 +46,7 @@ class AsapoReceiver: ...@@ -45,7 +46,7 @@ class AsapoReceiver:
"Name of input stream", type=str, default=""), "Name of input stream", type=str, default=""),
timeout=Config( timeout=Config(
"Allowed time in milliseconds for ASAP::O data access before " "Allowed time in milliseconds for ASAP::O data access before "
"exception is thrown", type=float, default=3) "exception is thrown", type=float, default=3000)
)) ))
group_id = Config( group_id = Config(
"The stream data is divided between all workers with the same " "The stream data is divided between all workers with the same "
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment