Skip to content

Commit

Permalink
Be compatible with hyperruns and fix code style
Browse files Browse the repository at this point in the history
  • Loading branch information
dachengx committed Jun 2, 2024
1 parent 7dba77c commit 0297fca
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion strax/chunk.py
Original file line number Diff line number Diff line change
Expand Up @@ -434,7 +434,7 @@ class Rechunker:

def __init__(self, rechunk=False, run_id=None):
self.rechunk = rechunk
self.is_superrun = (run_id and run_id.startswith("_"),)
self.is_superrun = run_id and run_id.startswith("_") and not run_id.startswith("__")
self.run_id = run_id

self.cache = None
Expand Down
2 changes: 1 addition & 1 deletion strax/processors/single_thread.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ def __init__(

self.post_office.register_producer(
p.iter(iters={dep: self.post_office.get_iter(dep, d) for dep in p.depends_on}),
topic=p.provides,
topic=strax.to_str_tuple(p.provides),
)

dtypes_built = {d: p for p in components.plugins.values() for d in p.provides}
Expand Down

0 comments on commit 0297fca

Please sign in to comment.