equal
deleted
inserted
replaced
78 socket = self._get_socket() |
78 socket = self._get_socket() |
79 if socket is None: |
79 if socket is None: |
80 return [501, "No socket handler defined in configuration file"] |
80 return [501, "No socket handler defined in configuration file"] |
81 socket.send_json(['get_jobs', {}]) |
81 socket.send_json(['get_jobs', {}]) |
82 return zmq_response(socket) |
82 return zmq_response(socket) |
|
83 |
|
84 def test_process(self): |
|
85 """Send test request to scheduler process""" |
|
86 socket = self._get_socket() |
|
87 if socket is None: |
|
88 return [501, "No socket handler defined in configuration file"] |
|
89 socket.send_json(['test', {}]) |
|
90 return zmq_response(socket) |