Skip to content
GitLab
Menu
Projects
Groups
Snippets
Help
Help
Support
Community forum
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
Menu
Open sidebar
FS-SC
AsapoWorker
Commits
f8be0563
Commit
f8be0563
authored
Dec 20, 2019
by
Tim Schoof
Browse files
Throw error when last record does not contain any valid acknowledged id
parent
b01c0b6c
Pipeline
#27
failed with stages
in 12 minutes and 5 seconds
Changes
1
Pipelines
1
Hide whitespace changes
Inline
Side-by-side
src/AsapoWorker/worker.py
View file @
f8be0563
...
@@ -84,6 +84,11 @@ class SerialWorker(Worker):
...
@@ -84,6 +84,11 @@ class SerialWorker(Worker):
last_output_metadata
[
"meta"
][
"acknowledged_ids"
])
last_output_metadata
[
"meta"
][
"acknowledged_ids"
])
except
KeyError
:
except
KeyError
:
last_acknowledged_id
=
0
last_acknowledged_id
=
0
if
last_acknowledged_id
<
0
:
raise
ValueError
(
"No valid acknowledged id in last record of output stream "
"last_acknowledged_id=%s"
,
last_acknowledged_id
)
input_start_id
=
last_acknowledged_id
+
1
input_start_id
=
last_acknowledged_id
+
1
output_start_id
=
last_output_id
+
1
output_start_id
=
last_output_id
+
1
return
input_start_id
,
output_start_id
return
input_start_id
,
output_start_id
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
.
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment