Open maitrungduc1410 opened 5 years ago
Hi guys, For now I'm trying to get current data inside the pipeline.
In the decoding, it takes data chunk sent from worker and in function process_data it will push the data into pipeline.
process_data
Is there anyway that I can get the total current data in pipeline?
Thank you!
Hi guys, For now I'm trying to get current data inside the pipeline.
In the decoding, it takes data chunk sent from worker and in function
process_data
it will push the data into pipeline.Is there anyway that I can get the total current data in pipeline?
Thank you!