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

worker_impl: style

This commit is contained in:
Robert Jördens 2016-04-05 15:38:49 +08:00
parent 8af8365440
commit 4759ea337b
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
artiq/master/worker_impl.py
View File

@ -9,7 +9,8 @@ import artiq
from artiq.protocols import pipe_ipc, pyon from artiq.protocols import pipe_ipc, pyon
from artiq.protocols.packed_exceptions import raise_packed_exc from artiq.protocols.packed_exceptions import raise_packed_exc
from artiq.tools import multiline_log_config, file_import from artiq.tools import multiline_log_config, file_import
from artiq.master.worker_db import DeviceManager, DatasetManager, get_hdf5_output from artiq.master.worker_db import (DeviceManager, DatasetManager,
get_hdf5_output)
from artiq.language.environment import is_experiment from artiq.language.environment import is_experiment
from artiq.language.core import set_watchdog_factory, TerminationRequested from artiq.language.core import set_watchdog_factory, TerminationRequested
from artiq.coredevice.core import CompileError, host_only, _render_diagnostic from artiq.coredevice.core import CompileError, host_only, _render_diagnostic
@ -18,6 +19,7 @@ from artiq import __version__ as artiq_version
ipc = None ipc = None
def get_object(): def get_object():
line = ipc.readline().decode() line = ipc.readline().decode()
return pyon.decode(line) return pyon.decode(line)
@ -84,7 +86,7 @@ class Scheduler:
delete = staticmethod(make_parent_action("scheduler_delete")) delete = staticmethod(make_parent_action("scheduler_delete"))
request_termination = staticmethod( request_termination = staticmethod(
make_parent_action("scheduler_request_termination")) make_parent_action("scheduler_request_termination"))
get_status = staticmethod(make_parent_action("scheduler_get_status")) get_status = staticmethod(make_parent_action("scheduler_get_status"))
def set_run_info(self, rid, pipeline_name, expid, priority): def set_run_info(self, rid, pipeline_name, expid, priority):
self.rid = rid self.rid = rid
@ -159,7 +161,8 @@ def setup_diagnostics(experiment_file, repository_path):
# putting inherently local objects (the diagnostic engine) into # putting inherently local objects (the diagnostic engine) into
# global slots, and there isn't any point in making it prettier by # global slots, and there isn't any point in making it prettier by
# wrapping it in layers of indirection. # wrapping it in layers of indirection.
artiq.coredevice.core._DiagnosticEngine.render_diagnostic = render_diagnostic artiq.coredevice.core._DiagnosticEngine.render_diagnostic = \
render_diagnostic
def main(): def main():