Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 3 additions & 2 deletions 01-hello/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
from workers import WorkerEntrypoint, Response


class Default(WorkerEntrypoint):
async def fetch(self, request, env):
return Response("Hello world!")
async def fetch(self, request, env):
return Response("Hello world!")
9 changes: 5 additions & 4 deletions 02-binding/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
from workers import WorkerEntrypoint, Response


class Default(WorkerEntrypoint):
async def fetch(selfrequest, env):
await env.FOO.put("bar", "baz")
bar = await env.FOO.get("bar")
return Response(bar) # returns "baz"
async def fetch(selfrequest, env):
await env.FOO.put("bar", "baz")
bar = await env.FOO.get("bar")
return Response(bar) # returns "baz"
13 changes: 8 additions & 5 deletions 04-langchain/src/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,11 +2,14 @@
from langchain_core.prompts import PromptTemplate
from langchain_openai import OpenAI


@handler
async def on_fetch(request, env):
prompt = PromptTemplate.from_template("Complete the following sentence: I am a {profession} and ")
llm = OpenAI(api_key=env.API_KEY)
chain = prompt | llm
prompt = PromptTemplate.from_template(
"Complete the following sentence: I am a {profession} and "
)
llm = OpenAI(api_key=env.API_KEY)
chain = prompt | llm

res = await chain.ainvoke({"profession": "electrician"})
return Response(res.split(".")[0].strip())
res = await chain.ainvoke({"profession": "electrician"})
return Response(res.split(".")[0].strip())
13 changes: 7 additions & 6 deletions 05-query-d1/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,15 +1,16 @@
from workers import WorkerEntrypoint, Response


class Default(WorkerEntrypoint):
async def fetch(self, request, env):
query = """
async def fetch(self, request, env):
query = """
SELECT quote, author
FROM qtable
ORDER BY RANDOM()
LIMIT 1;
"""
results = await env.DB.prepare(query).all()
data = results.results[0]
results = await env.DB.prepare(query).all()
data = results.results[0]

# Return a JSON response
return Response.json(data)
# Return a JSON response
return Response.json(data)
6 changes: 3 additions & 3 deletions 06-vendoring/src/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@


class Default(WorkerEntrypoint):
async def fetch(self, request, env):
import asgi
async def fetch(self, request, env):
import asgi

return await asgi.fetch(app, request, env)
return await asgi.fetch(app, request, env)


app = FastAPI()
Expand Down
Loading