Tests pinging the worker
(self, inspect)
| 30 | |
| 31 | @flaky |
| 32 | def test_ping(self, inspect): |
| 33 | """Tests pinging the worker""" |
| 34 | ret = inspect.ping() |
| 35 | assert len(ret) == 1 |
| 36 | assert ret[NODENAME] == {'ok': 'pong'} |
| 37 | # TODO: Check ping() is returning None after stopping worker. |
| 38 | # This is tricky since current test suite does not support stopping of |
| 39 | # the worker. |
| 40 | |
| 41 | @flaky |
| 42 | def test_clock(self, inspect): |