浏览代码

bug fix: crash with etl & process

Steve Nyemba 5 天之前
父节点
当前提交
befdf453f5
共有 1 个文件被更改,包括 3 次插入3 次删除
  1. 3 3
      bin/transport

+ 3 - 3
bin/transport

@@ -53,9 +53,9 @@ def wait(jobs):
     while jobs :
     while jobs :
         jobs = [thread for thread in jobs if thread.is_alive()]
         jobs = [thread for thread in jobs if thread.is_alive()]
         time.sleep(1)
         time.sleep(1)
-def wait (jobs):
-    while jobs :
-            jobs = [pthread for pthread in jobs if pthread.is_alive()]
+# def wait (jobs):
+#     while jobs :
+#             jobs = [pthread for pthread in jobs if pthread.is_alive()]
 
 
 @app_e.command(name="run")
 @app_e.command(name="run")
 def apply (path:Annotated[str,typer.Argument(help="path of the configuration file")],
 def apply (path:Annotated[str,typer.Argument(help="path of the configuration file")],