self = <swh.scheduler.tests.test_scheduler.TestScheduler object at 0x7f1e1265e7b8> swh_scheduler = <swh.scheduler.backend.SchedulerBackend object at 0x7f1e1265e080> def test_grab_ready_tasks(self, swh_scheduler): self._create_task_types(swh_scheduler) t = utcnow() task_type = TEMPLATES["git"]["type"] # Create tasks with and without priorities tasks = tasks_from_template( TEMPLATES["git"], t, num_priorities=NUM_PRIORITY_TASKS ) random.shuffle(tasks) swh_scheduler.create_tasks(tasks) first_ready_tasks = swh_scheduler.peek_ready_tasks(task_type, num_tasks=50) grabbed_tasks = swh_scheduler.grab_ready_tasks(task_type, num_tasks=50) for peeked, grabbed in zip(first_ready_tasks, grabbed_tasks): assert peeked["status"] == "next_run_not_scheduled" del peeked["status"] assert grabbed["status"] == "next_run_scheduled" del grabbed["status"] > assert peeked == grabbed E AssertionError: assert RealDictRow([...rity', None)]) == RealDictRow([...rity', None)]) E Omitting 5 identical items, use -vv to show E Differing items: E {'next_run': datetime.datetime(2021, 5, 6, 13, 52, 22, 572920, tzinfo=psycopg2.tz.FixedOffsetTimezone(offset=0, name=None))} != {'next_run': datetime.datetime(2021, 5, 6, 13, 52, 22, 572944, tzinfo=psycopg2.tz.FixedOffsetTimezone(offset=0, name=None))} E {'id': 20} != {'id': 4} E {'arguments': {'args': ['argument-099'], 'kwargs': {'kwarg099': 'bogus-kwarg'}}} != {'arguments': {'args': ['argument-075'], 'kwargs': {'kwarg075': 'bogus-kwarg'}}} E Full diff: E - RealDictRow([('id', 4),... E E ...Full output truncated (24 lines hidden), use '-vv' to show .tox/py3/lib/python3.7/site-packages/swh/scheduler/tests/test_scheduler.py:243: AssertionError