Merge pull request #250 from PrefectHQ/thread-kwarg

fix flow thread kwarg

examples/memory_between_flows.py

@@ -0,0 +1,20 @@
+import controlflow as cf
+
+thread_id = "test-thread"
+
+
+@cf.flow(thread=thread_id)
+def flow_1():
+    task = cf.Task("get the user's name", result_type=str, user_access=True)
+    return task
+
+
+@cf.flow(thread=thread_id)
+def flow_2():
+    task = cf.Task("write the user's name backwards, if you don't know it, say so")
+    return task
+
+
+if __name__ == "__main__":
+    flow_1()
+    flow_2()

src/controlflow/decorators.py

@@ -92,7 +92,7 @@ def wrapper(
         flow_kwargs = kwargs | (flow_kwargs or {})
 
         if thread is not None:
-            flow_kwargs.setdefault("thread", thread)
+            flow_kwargs.setdefault("thread_id", thread)
         if tools is not None:
             flow_kwargs.setdefault("tools", tools)
         if agents is not None: