We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f68a3de commit 35a3d3bCopy full SHA for 35a3d3b
scheduler/types/broker_types.py
@@ -34,7 +34,3 @@
34
}
35
36
TASK_TYPES = ["OnceTaskType", "RepeatableTaskType", "CronTaskType"]
37
-
38
39
-def is_pipeline(conn: ConnectionType) -> bool:
40
- return isinstance(conn, redis.client.Pipeline) or isinstance(conn, valkey.client.Pipeline)
0 commit comments