tests/test_monitor.py


1
2
3
4
5
6
7
8
9
10

from __future__ import unicode_literals


class TestPipeline(object):
    def test_monitor(self, r):
        with r.monitor() as m:
            r.ping()
            response = m.next_command()
            assert set(response.keys()) == {'time', 'db', 'client_address',
                                            'client_port', 'command'}