chore: dir structure

Author: grutt

…i-react/fast-api-react/backend/README.md fast-api-react/backend/README.mdfast-api-react/fast-api-react/backend/README.md renamed to fast-api-react/backend/README.md fast-api-react/fast-api-react/backend/README.md renamed to fast-api-react/backend/README.md

@@ -12,7 +12,7 @@ hatchet = "src.workflows.main:start"
 [tool.poetry.dependencies]
 python = "^3.8"
 python-dotenv = "^1.0.0"
-hatchet-sdk = "^0.9.4"
+hatchet-sdk = "0.10.0"
 uvicorn = {extras = ["standard"], version = "^0.27.0"}
 fastapi = "^0.109.0"
 openai = "^1.11.0"

…react/fast-api-react/backend/__init__.py fast-api-react/backend/__init__.pyfast-api-react/fast-api-react/backend/__init__.py renamed to fast-api-react/backend/__init__.py fast-api-react/fast-api-react/backend/__init__.py renamed to fast-api-react/backend/__init__.py

@@ -1,14 +1,15 @@
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
 from fastapi.responses import StreamingResponse
-
-from .models import MessageRequest
-
-from hatchet_sdk import Hatchet
 import uvicorn
 from dotenv import load_dotenv
 import json
 
+from hatchet_sdk import Hatchet
+
+from .models import MessageRequest
+
+
 load_dotenv()
 
 app = FastAPI()
@@ -30,6 +31,18 @@
 )
 
 
+@app.post("/message")
+def message(data: MessageRequest):
+
+    messageId = hatchet.client.admin.run_workflow("GenerateWorkflow", {
+        "request": data.model_dump()
+    })
+
+    # save step message id -> workflowRunId
+
+    return {"workflowRunId": messageId}
+
+
 def event_stream_generator(workflowRunId):
     stream = hatchet.client.listener.stream(workflowRunId)
 
@@ -39,33 +52,16 @@ def event_stream_generator(workflowRunId):
             "payload": event.payload,
             "workflowRunId": workflowRunId
         })
-
-        #     stream.abort()
-        print(data)
         yield "data: " + data + "\n\n"
 
 
 @app.get("/stream/{messageId}")
 async def stream(messageId: str):
     # message id -> workflowRunId
     workflowRunId = messageId
-    # stream = hatchet.stream(workflowRunId)
     return StreamingResponse(event_stream_generator(workflowRunId), media_type='text/event-stream')
 
 
-@app.post("/message")
-def message(data: MessageRequest):
-    print(data.model_dump())
-
-    messageId = hatchet.client.admin.run_workflow("GenerateWorkflow", {
-        "request": data.model_dump()
-    })
-
-    # save step message id -> workflowRunId
-
-    return {"workflowRunId": messageId}
-
-
 def start():
-    """Launched with `poetry run start` at root level"""
+    """Launched with `poetry run api` at root level"""
     uvicorn.run("src.api.main:app", host="0.0.0.0", port=8000, reload=True)

…react/fast-api-react/backend/poetry.lock fast-api-react/backend/poetry.lockfast-api-react/fast-api-react/backend/poetry.lock renamed to fast-api-react/backend/poetry.lock fast-api-react/fast-api-react/backend/poetry.lock renamed to fast-api-react/backend/poetry.lock

@@ -8,39 +8,6 @@
 openai = OpenAI()
 
 
-@hatchet.workflow(on_events=["trigger:create"])
-class ManualTriggerWorkflow:
-    @hatchet.step()
-    def step1(self, context):
-        messages = context.workflow_input()['request']['messages']
-        print("> starting step1", messages)
-        return {"status": "thinking"}
-
-    @hatchet.step(parents=["step1"])
-    def step2(self, context):
-        print("starting step2")
-        return {"status": "writing a response"}
-
-    @hatchet.step(parents=["step2"], timeout='5m')
-    def step3(self, context):
-        messages = context.workflow_input()['request']['messages']
-        prompt = "Compose a poem that explains the concept of recursion in programming."
-        model = "gpt-3.5-turbo"
-
-        completion = openai.chat.completions.create(
-            model=model,
-            messages=[
-                {"role": "system", "content": prompt},
-            ] + messages
-        )
-
-        return {
-            "complete": "true",
-            "status": "idle",
-            "message": completion.choices[0].message.content,
-        }
-
-
 @hatchet.workflow(on_events=["question:create"])
 class GenerateWorkflow: