AsapoWorker merge requestshttps://gitlab.desy.de/fs-sc/asapoworker/-/merge_requests2023-06-19T10:02:57+02:00https://gitlab.desy.de/fs-sc/asapoworker/-/merge_requests/56Add option set set stream to latest2023-06-19T10:02:57+02:00Mikhail KarnevskiyAdd option set set stream to latest@tim.schoof
Often p02.2 wants to start pipeline with latest stream to process currently taking data. I would suggest to introduce this option here.@tim.schoof
Often p02.2 wants to start pipeline with latest stream to process currently taking data. I would suggest to introduce this option here.https://gitlab.desy.de/fs-sc/asapoworker/-/merge_requests/29Change timeout from s to ms2021-05-17T14:30:58+02:00Mikhail KarnevskiyChange timeout from s to ms@tim.schoof
Asapo producer requires timeout in ms.@tim.schoof
Asapo producer requires timeout in ms.https://gitlab.desy.de/fs-sc/asapoworker/-/merge_requests/18Acknowledgements2021-05-17T14:30:40+02:00Tim SchoofAcknowledgementsAcknowledgements are sent to input data_source with respect to output data_source. In order to implement it output data source is encoded by numbers and used as group_id by acknowledgement.
Before starting worker choose an input stream ...Acknowledgements are sent to input data_source with respect to output data_source. In order to implement it output data source is encoded by numbers and used as group_id by acknowledgement.
Before starting worker choose an input stream for a given data_source, that contains non-acknowledged messages.https://gitlab.desy.de/fs-sc/asapoworker/-/merge_requests/25Fix workers without metadata stream2021-04-16T16:35:14+02:00Tim SchoofFix workers without metadata streamThis is a temporary hack until the different stream naming schemes
become obsolete due to further improvements like acknowledgements.This is a temporary hack until the different stream naming schemes
become obsolete due to further improvements like acknowledgements.https://gitlab.desy.de/fs-sc/asapoworker/-/merge_requests/9Feat: Add function for likely_done case2020-10-30T11:55:59+01:00Mikhail KarnevskiyFeat: Add function for likely_done case@tim.schoof
Creation of new thread for new substream is quite special situation. It may be useful for worker to know it.
I have a used case: My worker have ZMQ connection on certain port. New connection can not be established in the n...@tim.schoof
Creation of new thread for new substream is quite special situation. It may be useful for worker to know it.
I have a used case: My worker have ZMQ connection on certain port. New connection can not be established in the new thread, because port is busy. Old connection should be closed.