Commit 90a632ef authored by Tim Schoof's avatar Tim Schoof
Browse files

Add retrieve_data method to receiver

parent cdc97ad2
Pipeline #26945 passed with stage
in 1 minute and 7 seconds
......@@ -166,6 +166,12 @@ class SimpleAsapoReceiver:
except asapo_consumer.AsapoConsumerError as err:
raise StreamError("Failed to get stream meta") from err
def retrieve_data(self, meta):
try:
return self.consumer.retrieve_data(meta)
except asapo_consumer.AsapoConsumerError as err:
raise StreamError("Failed to retrieve data") from err
# TODO: Ensure also that indices are consecutive or start at 0
@Configurable
......
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