Skip to content

A
aidso-data
Commit 31d15caf authored by Yaowentong's avatar Yaowentong
Browse files
Options

修复process

parent ea577486
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
aidso_geo/core/success_process.py
View file @ 31d15caf
...@@ -176,7 +176,7 @@ def batch_worker(): ...@@ -176,7 +176,7 @@ def batch_worker():
def main(): def main():
thread_list = [ thread_list = [
threading.Thread(target=processing_worker, name="processing_worker", daemon=True), # threading.Thread(target=processing_worker, name="processing_worker", daemon=True),
threading.Thread(target=stream_worker, name="stream_worker", daemon=True), threading.Thread(target=stream_worker, name="stream_worker", daemon=True),
threading.Thread(target=stream_batch_worker, name="stream_batch_worker", daemon=True), threading.Thread(target=stream_batch_worker, name="stream_batch_worker", daemon=True),
threading.Thread(target=batch_worker, name="batch_worker", daemon=True), threading.Thread(target=batch_worker, name="batch_worker", daemon=True),
......
Markdown is supported
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