Fully qualify class names in repr(), add selected state information

This is intended to disambiguate objects in log and debug output.

Author: moreati

ansible_mitogen/planner.py

@@ -114,7 +114,10 @@ def get_module_source(self):
         return self._module_source
 
     def __repr__(self):
-        return 'Invocation(module_name=%s)' % (self.module_name,)
+        return '%s.%s(module_name=%r)' % (
+            __name__, self.__class__.__name__,
+            self.module_name,
+        )
 
 
 class Planner(object):

ansible_mitogen/runner.py

@@ -177,7 +177,7 @@ def __init__(self, path):
         LOG.debug('%r installed; existing keys: %r', self, self._keys)
 
     def __repr__(self):
-        return 'EnvironmentFileWatcher(%r)' % (self.path,)
+        return '%s.%s(%r)' % (__name__, self.__class__.__name__, self.path)
 
     def _stat(self):
         try:

docs/changelog.rst

@@ -21,6 +21,8 @@ To avail of fixes in an unreleased version, please download a ZIP file
 In progress (unreleased)
 ------------------------
 
+* :gh:issue:`1318` Fully qualify class names in ``repr()``, add selected state
+
 
 v0.3.26 (2025-08-04)
 --------------------

mitogen/core.py

@@ -327,7 +327,7 @@ def __init__(self, dct):
                 self[k] = v
 
     def __repr__(self):
-        return 'Kwargs(%s)' % (dict.__repr__(self),)
+        return '%s(%s)' % (self.__class__.__name__, dict.__repr__(self),)
 
     def __reduce__(self):
         return (Kwargs, (dict(self),))
@@ -1018,7 +1018,8 @@ def unpickle(self, throw=True, throw_dead=True):
         return obj
 
     def __repr__(self):
-        return 'Message(%r, %r, %r, %r, %r, %r..%d)' % (
+        return '%s.%s(dst_id=%r, src_id=%r, auth_id=%r, handle=%r, reply_to=%r, data=%r..%d)' % (
+            __name__, self.__class__.__name__,
             self.dst_id, self.src_id, self.auth_id, self.handle,
             self.reply_to, (self.data or '')[:50], len(self.data)
         )
@@ -1064,7 +1065,10 @@ def close(self):
         )
 
     def __repr__(self):
-        return 'Sender(%r, %r)' % (self.context, self.dst_handle)
+        return '%s.%s(%r, %r)' % (
+            __name__, self.__class__.__name__,
+            self.context, self.dst_handle,
+        )
 
     def __reduce__(self):
         return _unpickle_sender, (self.context.context_id, self.dst_handle)
@@ -1126,7 +1130,10 @@ def __init__(self, router, handle=None, persist=True,
         )
 
     def __repr__(self):
-        return 'Receiver(%r, %r)' % (self.router, self.handle)
+        return '%s.%s(%r, %r)' % (
+            __name__, self.__class__.__name__,
+            self.router, self.handle,
+        )
 
     def __enter__(self):
         return self
@@ -1276,7 +1283,8 @@ def close(self):
         Sender.close(self)
 
     def __repr__(self):
-        return 'Channel(%s, %s)' % (
+        return '%s.%s(%s, %s)' % (
+            __name__, self.__class__.__name__,
             Sender.__repr__(self),
             Receiver.__repr__(self)
         )
@@ -1390,7 +1398,7 @@ def _install_handler(self, router):
         )
 
     def __repr__(self):
-        return 'Importer'
+        return '%s.%s()' % (__name__, self.__class__.__name__)
 
     @staticmethod
     def _loader_from_module(module, default=None):
@@ -1895,7 +1903,10 @@ def accept(self, rfp, wfp):
         self.transmit_side = Side(self, wfp)
 
     def __repr__(self):
-        return "<Stream %s #%04x>" % (self.name, id(self) & 0xffff,)
+        return "<%s.%s %r #%04x>" % (
+            __name__, self.__class__.__name__,
+            self.name, id(self) & 0xffff,
+        )
 
     def on_receive(self, broker):
         """
@@ -1988,8 +1999,8 @@ def build_stream(cls, *args, **kwargs):
         return stream
 
     def __repr__(self):
-        return '%s(%s)' % (
-            self.__class__.__name__,
+        return '%s.%s(%r)' % (
+            __name__, self.__class__.__name__,
             self.stream and self.stream.name,
         )
 
@@ -2179,8 +2190,9 @@ def __init__(self, stream, fp, cloexec=True, keep_alive=True):
             set_cloexec(self.fd)
 
     def __repr__(self):
-        return '<Side of %s fd %s>' % (
-            self.stream.name or repr(self.stream),
+        return '<%s.%s of %r fd %r>' % (
+            __name__, self.__class__.__name__,
+            self.stream.name or self.stream,
             self.fd
         )
 
@@ -2505,7 +2517,10 @@ def send_await(self, msg, deadline=None):
         return data
 
     def __repr__(self):
-        return 'Context(%s, %r)' % (self.context_id, self.name)
+        return '%s.%s(%r, %r)' % (
+            __name__, self.__class__.__name__,
+            self.context_id, self.name,
+        )
 
 
 def _unpickle_context(context_id, name, router=None):
@@ -2561,7 +2576,10 @@ def __init__(self):
         self._wfds = {}
 
     def __repr__(self):
-        return '%s' % (type(self).__name__,)
+        return '<%s.%s with %d readers %d writers>' % (
+            __name__, self.__class__.__name__,
+            len(self._rfds), len(self._wfds),
+        )
 
     def _update(self, fd):
         """
@@ -2932,7 +2950,8 @@ def _wake(self, wsock, cookie):
         assert written == len(cookie) and not disconnected
 
     def __repr__(self):
-        return 'Latch(%#x, size=%d, t=%r)' % (
+        return '%s.%s(%#x, size=%d, thread=%r)' % (
+            __name__, self.__class__.__name__,
             id(self),
             len(self._queue),
             threading__thread_name(threading__current_thread()),
@@ -2962,9 +2981,9 @@ def __init__(self, broker):
         self._deferred = collections.deque()
 
     def __repr__(self):
-        return 'Waker(fd=%r/%r)' % (
-            self.stream.receive_side and self.stream.receive_side.fd,
-            self.stream.transmit_side and self.stream.transmit_side.fd,
+        return '%s.%s(%r, %r)' % (
+            __name__, self.__class__.__name__,
+            self.stream.receive_side, self.stream.transmit_side,
         )
 
     @property
@@ -3155,7 +3174,7 @@ def __init__(self, broker):
         self.add_handler(self._on_del_route, DEL_ROUTE)
 
     def __repr__(self):
-        return 'Router(%r)' % (self.broker,)
+        return '%s.%s(%r)' % (__name__, self.__class__.__name__, self.broker)
 
     def _setup_logging(self):
         """
@@ -3791,7 +3810,7 @@ def join(self):
         self._thread.join()
 
     def __repr__(self):
-        return 'Broker(%04x)' % (id(self) & 0xffff,)
+        return '%s.%s(%r)' % (__name__, self.__class__.__name__, self.poller)
 
 
 class Dispatcher(object):
@@ -3808,7 +3827,7 @@ class Dispatcher(object):
     _service_recv = None
 
     def __repr__(self):
-        return 'Dispatcher'
+        return '%s.%s(%r)' % (__name__, self.__class__.__name__, self.econtext)
 
     def __init__(self, econtext):
         self.econtext = econtext

mitogen/fakessh.py

@@ -160,9 +160,9 @@ def on_receive(self, stream, broker):
             self.on_disconnect(broker)
 
     def __repr__(self):
-        return 'IoPump(%r, %r)' % (
-            self.receive_side.fp.fileno(),
-            self.transmit_side.fp.fileno(),
+        return '%s.%s(%r, %r)' % (
+            __name__, self.__class__.__name__,
+            self.receive_side, self.transmit_side,
         )
 
 
@@ -195,7 +195,10 @@ def __init__(self, router, stdin, stdout, proc=None):
             pmon.add(proc.pid, self._on_proc_exit)
 
     def __repr__(self):
-        return 'Process(%r, %r)' % (self.stdin, self.stdout)
+        return '%s.%s(%r, %r, %r)' % (
+            __name__, self.__class__.__name__,
+            self.router, self.stdin, self.stdout,
+        )
 
     def _on_proc_exit(self, status):
         LOG.debug('%r._on_proc_exit(%r)', self, status)

mitogen/master.py

@@ -465,7 +465,7 @@ def _on_forward_log(self, msg):
         logger.handle(record)
 
     def __repr__(self):
-        return 'LogForwarder(%r)' % (self._router,)
+        return '%s.%s(%r)' % (__name__, self.__class__.__name__, self._router)
 
 
 class FinderMethod(object):
@@ -478,7 +478,7 @@ def __init__(self):
         self.log = LOG.getChild(self.__class__.__name__)
 
     def __repr__(self):
-        return '%s()' % (type(self).__name__,)
+        return '%s.%s()' % (__name__, self.__class__.__name__)
 
     def find(self, fullname):
         """
@@ -927,7 +927,7 @@ def __init__(self):
         self._related_cache = {}
 
     def __repr__(self):
-        return 'ModuleFinder()'
+        return '%s.%s()' % (__name__, self.__class__.__name__)
 
     def add_source_override(self, fullname, path, source, is_pkg):
         """
@@ -1110,7 +1110,7 @@ def __init__(self, router):
         )
 
     def __repr__(self):
-        return 'ModuleResponder'
+        return '%s.%s(%r)' % (__name__, self.__class__.__name__, self._router)
 
     def add_source_override(self, fullname, path, source, is_pkg):
         """
@@ -1527,7 +1527,7 @@ def __init__(self, router):
         )
 
     def __repr__(self):
-        return 'IdAllocator(%r)' % (self.router,)
+        return '%s.%s(%r)' % (__name__, self.__class__.__name__, self.router)
 
     def allocate(self):
         """

mitogen/parent.py

@@ -595,7 +595,10 @@ def __init__(self, when, func):
         self.func = func
 
     def __repr__(self):
-        return 'Timer(%r, %r)' % (self.when, self.func)
+        return '%s.%s(%r, %r)' % (
+            __name__, self.__class__.__name__,
+            self.when, self.func,
+        )
 
     def __eq__(self, other):
         return self.when == other.when
@@ -1389,7 +1392,9 @@ def __init__(self, options, router):
         self._router = router
 
     def __repr__(self):
-        return 'Connection(%r)' % (self.stdio_stream,)
+        return '%s.%s(stdio_stream=%r)' % (
+            __name__, self.__class__.__name__, self.stdio_stream,
+        )
 
     # Minimised, gzipped, base64'd and passed to 'python -c'. It forks, dups
     # file descriptor 0 as 100, creates a pipe, then execs a new interpreter
@@ -1832,7 +1837,7 @@ def make_chain_id(cls):
         )
 
     def __repr__(self):
-        return '%s(%s)' % (self.__class__.__name__, self.context)
+        return '%s.%s(%r)' % (__name__, self.__class__.__name__, self.context)
 
     def __enter__(self):
         return self
@@ -2112,7 +2117,10 @@ def __init__(self, router, parent=None):
         )
 
     def __repr__(self):
-        return 'RouteMonitor()'
+        return '%s.%s(%r, %r)' % (
+            __name__, self.__class__.__name__,
+            self.router, self.parent,
+        )
 
     def _send_one(self, stream, handle, target_id, name):
         """
@@ -2652,8 +2660,8 @@ def __init__(self, pid, stdin, stdout, stderr=None):
         self.stderr = stderr
 
     def __repr__(self):
-        return '%s %s pid %d' % (
-            type(self).__name__,
+        return '%s.%s(%r, %r)' % (
+            __name__, self.__class__.__name__,
             self.name,
             self.pid,
         )
@@ -2724,7 +2732,10 @@ def __init__(self, router, parent_context, importer):
         )
 
     def __repr__(self):
-        return 'ModuleForwarder'
+        return '%s.%s(%r, %r, %r)' % (
+            __name__, self.__class__.__name__,
+            self.router, self.parent_context, self.importer,
+        )
 
     def _on_forward_module(self, msg):
         if msg.is_dead:

mitogen/service.py

@@ -254,7 +254,7 @@ def __init__(self, service):
         self.service = service
 
     def __repr__(self):
-        return '%s(%s)' % (type(self).__name__, self.service)
+        return '%s.%s(%r)' % (__name__, self.__class__.__name__, self.service)
 
     unauthorized_msg = (
         'Caller is not authorized to invoke %r of service %r'
@@ -440,7 +440,9 @@ def __init__(self, router):
         self.select = mitogen.select.Select()
 
     def __repr__(self):
-        return '%s()' % (self.__class__.__name__,)
+        return '%s.%s(%r, %r)' % (
+            __name__, self.__class__.__name__, self.router, self.select,
+        )
 
     def on_message(self, event):
         """
@@ -653,7 +655,8 @@ def _worker_main(self):
             raise
 
     def __repr__(self):
-        return 'Pool(%04x, size=%d, th=%r)' % (
+        return '%s.%s(%04x, size=%d, th=%r)' % (
+            __name__, self.__class__.__name__,
             id(self) & 0xffff,
             len(self._threads),
             get_thread_name(),

tests/importer_test.py

@@ -46,6 +46,11 @@ def tearDown(self):
         super(ImporterMixin, self).tearDown()
 
 
+class ImporterTest(ImporterMixin, testlib.TestCase):
+    def test_repr(self):
+        self.assertEqual('mitogen.core.Importer()', repr(self.importer))
+
+
 class InvalidNameTest(ImporterMixin, testlib.TestCase):
     modname = 'trailingdot.'
     # 0:fullname 1:pkg_present 2:path 3:compressed 4:related