srenblad/artiq
1
0
Fork 0
forked from M-Labs/artiq
Code Pull Requests Activity

worker_impl: style fixes (NFC)

Browse Source
This commit is contained in:
Sébastien Bourdeauducq 2024-02-27 10:39:37 +08:00
parent 7688f380b1
commit a8a5fc213b
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
artiq/master/worker_impl.py
View File

@ -200,9 +200,7 @@ def examine(device_mgr, dataset_mgr, file):
name = name[:-1] name = name[:-1]
argument_mgr = TraceArgumentManager() argument_mgr = TraceArgumentManager()
scheduler_defaults = {} scheduler_defaults = {}
cls = exp_class( # noqa: F841 (fill argument_mgr) exp_class((device_mgr, dataset_mgr, argument_mgr, scheduler_defaults))
(device_mgr, dataset_mgr, argument_mgr, scheduler_defaults)
)
arginfo = OrderedDict( arginfo = OrderedDict(
(k, (proc.describe(), group, tooltip)) (k, (proc.describe(), group, tooltip))
for k, (proc, group, tooltip) in argument_mgr.requested_args.items() for k, (proc, group, tooltip) in argument_mgr.requested_args.items()
@ -325,8 +323,8 @@ def main():
rid, obj["pipeline_name"], expid, obj["priority"]) rid, obj["pipeline_name"], expid, obj["priority"])
start_local_time = time.localtime(start_time) start_local_time = time.localtime(start_time)
dirname = os.path.join("results", dirname = os.path.join("results",
time.strftime("%Y-%m-%d", start_local_time), time.strftime("%Y-%m-%d", start_local_time),
time.strftime("%H", start_local_time)) time.strftime("%H", start_local_time))
os.makedirs(dirname, exist_ok=True) os.makedirs(dirname, exist_ok=True)
os.chdir(dirname) os.chdir(dirname)
argument_mgr = ProcessArgumentManager(expid["arguments"]) argument_mgr = ProcessArgumentManager(expid["arguments"])