wip feat: add redis-based queue
CI / lint (push) Skipped
CI / test (3.12) (push) Skipped
CI / test (3.13) (push) Skipped
CI / test-with-beamline-plugins (pxi_bec) (push) Skipped
CI / test-with-beamline-plugins (pxii_bec) (push) Skipped
CI / test-with-beamline-plugins (pxiii_bec) (push) Skipped
CI / lint (push) Skipped
CI / test (3.12) (push) Skipped
CI / test (3.13) (push) Skipped
CI / test-with-beamline-plugins (pxi_bec) (push) Skipped
CI / test-with-beamline-plugins (pxii_bec) (push) Skipped
CI / test-with-beamline-plugins (pxiii_bec) (push) Skipped
This commit is contained in:
1 parent
a2e29a455d
commit
496a7bd098
2 files changed
+1
-5
No files matched your search
@@ -87,8 +87,7 @@ def parse_queue_item(raw: str | bytes) -> AareQueueItem:
|
||||
ValueError: the entry is not valid JSON, carries no usable id/kind, or
|
||||
is a malformed instance of a kind we do recognise -- all corrupt
|
||||
rather than merely unrecognised.
|
||||
TypeError: the entry is valid JSON but not an object, so there is no
|
||||
payload a forward-compatible reader could preserve.
|
||||
TypeError: the entry is valid JSON but not an object
|
||||
"""
|
||||
try:
|
||||
return _KNOWN_ADAPTER.validate_json(raw)
|
||||
|
||||
@@ -21,9 +21,6 @@ BEAMLINE = MXBeamline.X10SA
|
||||
QUEUE_KEY = str(BEAMLINE) + QUEUE_KEY_SUFFIX
|
||||
NOTIFY_CHANNEL = str(BEAMLINE) + QUEUE_NOTIFICATION_CHANNEL_SUFFIX
|
||||
|
||||
# Callbacks run on the client's dispatch thread, so tests wait on an Event
|
||||
# rather than sleeping. Generous enough for a loaded CI box, but only ever
|
||||
# paid in full when something is actually broken.
|
||||
DISPATCH_TIMEOUT_S = 2.0
|
||||
# Waiting for something NOT to happen has to be a real sleep; keep it short.
|
||||
QUIET_PERIOD_S = 0.3
|
||||
|
||||
Reference in new issue
Block a user