correcting symbol

Author: samuelcolvin

arq/main.py

@@ -120,11 +120,11 @@ async def enqueue_job(self, func_name: str, *args, queue: str=None, **kwargs):
         if self._concurrency_enabled:
             # use the pool directly rather than get_redis_conn to avoid one extra await
             pool = self._redis_pool or await self.get_redis_pool()
-            main_logger.debug('%s.%s ▶ %s', self.name, func_name, queue)
+            main_logger.debug('%s.%s → %s', self.name, func_name, queue)
             async with pool.get() as redis:
                 await self.job_future(redis, queue, func_name, *args, **kwargs)
         else:
-            main_logger.debug('%s.%s ▶ %s (called directly)', self.name, func_name, queue)
+            main_logger.debug('%s.%s → %s (called directly)', self.name, func_name, queue)
             data = self.job_class.encode(class_name=self.name, func_name=func_name, args=args, kwargs=kwargs)
             j = self.job_class(data, queue_name=queue)
             await getattr(self, j.func_name).direct(*j.args, **j.kwargs)

tests/test_main.py

@@ -54,8 +54,8 @@ async def test_dispatch_work(tmpworkdir, loop, caplog, redis_conn):
     assert None is await actor.high_add_numbers(3, 4, c=5)
     assert len(actor.mock_data[b'arq:q:dft']) == 1
     assert len(actor.mock_data[b'arq:q:high']) == 1
-    assert caplog.log == ('MockRedisDemoActor.add_numbers ▶ dft\n'
-                          'MockRedisDemoActor.high_add_numbers ▶ high\n')
+    assert caplog.log == ('MockRedisDemoActor.add_numbers → dft\n'
+                          'MockRedisDemoActor.high_add_numbers → high\n')
     worker = MockRedisWorker(burst=True, loop=actor.loop)
     worker.mock_data = actor.mock_data
     assert not tmpworkdir.join('add_numbers').exists()
@@ -66,8 +66,8 @@ async def test_dispatch_work(tmpworkdir, loop, caplog, redis_conn):
     log = re.sub(r'\d{4}-\d+-\d+ \d+:\d+:\d+', '<date time>', log)
     log = re.sub(r'\w{3}-\d+ \d+:\d+:\d+', '<date time2>', log)
     print(log)
-    assert ('MockRedisDemoActor.add_numbers ▶ dft\n'
-            'MockRedisDemoActor.high_add_numbers ▶ high\n'
+    assert ('MockRedisDemoActor.add_numbers → dft\n'
+            'MockRedisDemoActor.high_add_numbers → high\n'
             'Initialising work manager, burst mode: True, creating shadows...\n'
             'Using first shadows job class "Job"\n'
             'Running worker with 1 shadow listening to 3 queues\n'