SciCatProject / scicat-filewriter-ingest

Python client that connects to a kafka queue and creates new datasets when receiving notification that a file has been written
0 stars 0 forks source link

Add more integration helpers. #24

Closed YooSunYoung closed 1 month ago

YooSunYoung commented 1 month ago

It also has wrdn message receiving loop. Note that it's no longer while-loop. It's a generator, so no need to break the loop.

tests/_scicat_ingestor.py

This script helps to run scicat_ingestor but it sends a keyboard-interrupt signal in 5 seconds and kill the process after another 5 seconds. We can make it configurable later if needed. : D