Mirror of https://github.com/roostorg/osprey
github.com/roostorg/osprey
patch gevent immediately for `cli/sinks.py` (#35)
+3
-2
+3
-2
osprey_worker/src/osprey/worker/cli/sinks.py
+3
-2
osprey_worker/src/osprey/worker/cli/sinks.py
···
2
2
# ruff: noqa: E402, E501
3
3
4
4
from osprey.worker.lib.patcher import patch_all
5
-
from osprey.worker.sinks.input_stream_chooser import get_rules_sink_input_stream
6
-
from osprey.worker.sinks.sink.output_sink import LabelOutputSink
7
5
6
+
# do not move this below other imports
8
7
patch_all(ddtrace_args={'cassandra': True, 'psycopg': True})
9
8
9
+
from osprey.worker.sinks.input_stream_chooser import get_rules_sink_input_stream
10
+
from osprey.worker.sinks.sink.output_sink import LabelOutputSink
10
11
11
12
import signal
12
13
from uuid import uuid1