Commit eb9833f4 authored by Tim Schoof's avatar Tim Schoof
Browse files

Increase timeout default value

parent 81e399ed
......@@ -23,6 +23,7 @@ def create_broker(source, path, beamtime, stream, token, timeout):
return broker
# TODO: Ensure also that indices are consecutive or start at 0
@Configurable
class AsapoReceiver:
"""
......@@ -45,7 +46,7 @@ class AsapoReceiver:
"Name of input stream", type=str, default=""),
timeout=Config(
"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(
"The stream data is divided between all workers with the same "
......
......@@ -80,7 +80,7 @@ class AsapoSender:
"Name of output stream", type=str, default=""),
timeout=Config(
"Allowed time in milliseconds for ASAP::O data access before "
"exception is thrown", type=float, default=3)
"exception is thrown", type=float, default=3000)
))
ingest_mode = Config(
"The ingest mode determines how the data is handled by ASAP::O. "
......
Supports Markdown
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