Fix merge conflict of renaming transfer log

dask · Aug 31, 2022 · 093d7dc · 093d7dc
1 parent 9d99d74
commit 093d7dc
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/distributed/tests/test_scheduler.py b/distributed/tests/test_scheduler.py
@@ -261,12 +261,8 @@ async def test_decide_worker_coschedule_order_binary_op(c, s, a, b, ngroups):
 
     await c.gather(c.compute(zs))
 
-    assert not a.state.incoming_transfer_log, [
-        l["keys"] for l in a.state.incoming_transfer_log
-    ]
-    assert not b.state.incoming_transfer_log, [
-        l["keys"] for l in b.state.incoming_transfer_log
-    ]
+    assert not a.transfer_incoming_log, [l["keys"] for l in a.transfer_incoming_log]
+    assert not b.transfer_incoming_log, [l["keys"] for l in b.transfer_incoming_log]
 
 
 @pytest.mark.slow