Skip to content

Commit 625e7f2

Browse files
authored
Forbid multi-threading (#114)
* dont use multiple thread * debug
1 parent bc97fea commit 625e7f2

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

outsource/workflow/runstrax.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -156,7 +156,7 @@ def process(runid,
156156
# if we didn't pass any chunks, we process the whole thing -- otherwise just do the chunks we listed
157157
if chunks is None:
158158
# check if we need to save anything, if not, skip this plugin
159-
if plugin.save_when == strax.SaveWhen.NEVER:
159+
if plugin.save_when[out_dtype] == strax.SaveWhen.NEVER:
160160
print("This plugin is not saving anything. Skipping.")
161161
return
162162

@@ -165,8 +165,6 @@ def process(runid,
165165
for keystring in plugin.provides:
166166
print(f"Making {keystring}")
167167
st.make(runid_str, keystring,
168-
max_workers=4, #FIXME is it dangerous?
169-
allow_multiple=True,
170168
save=keystring,
171169
)
172170
print(f"DONE processing {keystring}")

0 commit comments

Comments
 (0)