We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f100725 commit e254b88Copy full SHA for e254b88
tests/test_tracer.py
@@ -10,6 +10,12 @@ def test_traced_task(tmp_path):
10
app = make_app("tests.tasks")
11
assert isinstance(app.connector, InMemoryConnector)
12
13
+ # Reset stale notification handler from previous tests — the cached
14
+ # InMemoryConnector may still reference a closed event loop from an
15
+ # earlier sync worker run, causing _notify to fail with
16
+ # "Event loop is closed" when it tries cross-thread scheduling.
17
+ app.connector.on_notification = None
18
+
19
entity = ftm_model.make_entity("Person")
20
entity.id = "test-entity-123"
21
entity.add("name", "Test Person")
0 commit comments