From e83660885b423ef7fef5677ac6822d5c14f2f313 Mon Sep 17 00:00:00 2001 From: Nuno Campos Date: Wed, 15 Jan 2025 13:39:44 -0800 Subject: [PATCH] Lint --- libs/scheduler-kafka/tests/test_subgraph.py | 6 ------ libs/scheduler-kafka/tests/test_subgraph_sync.py | 6 ------ 2 files changed, 12 deletions(-) diff --git a/libs/scheduler-kafka/tests/test_subgraph.py b/libs/scheduler-kafka/tests/test_subgraph.py index 047d3a7c8..88042b28a 100644 --- a/libs/scheduler-kafka/tests/test_subgraph.py +++ b/libs/scheduler-kafka/tests/test_subgraph.py @@ -203,7 +203,6 @@ async def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": None, "checkpoint_map": { "": history[0].config["configurable"]["checkpoint_id"] @@ -275,7 +274,6 @@ async def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": c.config["configurable"]["checkpoint_id"], "checkpoint_map": { "": history[0].config["configurable"]["checkpoint_id"] @@ -377,7 +375,6 @@ async def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": c.config["configurable"]["checkpoint_id"], "checkpoint_map": { "": history[0].config["configurable"]["checkpoint_id"] @@ -489,7 +486,6 @@ async def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": None, "checkpoint_map": { "": history[1].config["configurable"]["checkpoint_id"] @@ -556,7 +552,6 @@ async def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": c.config["configurable"]["checkpoint_id"], "checkpoint_map": { "": history[1].config["configurable"]["checkpoint_id"] @@ -679,7 +674,6 @@ async def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": c.config["configurable"]["checkpoint_id"], "checkpoint_map": { "": history[1].config["configurable"]["checkpoint_id"] diff --git a/libs/scheduler-kafka/tests/test_subgraph_sync.py b/libs/scheduler-kafka/tests/test_subgraph_sync.py index 84e76b6a4..30b70720f 100644 --- a/libs/scheduler-kafka/tests/test_subgraph_sync.py +++ b/libs/scheduler-kafka/tests/test_subgraph_sync.py @@ -202,7 +202,6 @@ def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": None, "checkpoint_map": { "": history[0].config["configurable"]["checkpoint_id"] @@ -274,7 +273,6 @@ def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": c.config["configurable"]["checkpoint_id"], "checkpoint_map": { "": history[0].config["configurable"]["checkpoint_id"] @@ -376,7 +374,6 @@ def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": c.config["configurable"]["checkpoint_id"], "checkpoint_map": { "": history[0].config["configurable"]["checkpoint_id"] @@ -487,7 +484,6 @@ def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": None, "checkpoint_map": { "": history[1].config["configurable"]["checkpoint_id"] @@ -554,7 +550,6 @@ def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": c.config["configurable"]["checkpoint_id"], "checkpoint_map": { "": history[1].config["configurable"]["checkpoint_id"] @@ -677,7 +672,6 @@ def test_subgraph_w_interrupt( "null_resume": None, "resume": [], }, - "__pregel_writes": AnyList(), "checkpoint_id": c.config["configurable"]["checkpoint_id"], "checkpoint_map": { "": history[1].config["configurable"]["checkpoint_id"]