Skip to content
Open
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
4 changes: 2 additions & 2 deletions .pre-commit-config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ repos:
- id: requirements-txt-fixer

- repo: https://github.com/codespell-project/codespell
rev: "v2.4.1"
rev: "v2.4.3"
hooks:
- id: codespell
exclude: |
Expand All @@ -25,7 +25,7 @@ repos:
)$

- repo: https://github.com/astral-sh/ruff-pre-commit
rev: v0.14.3
rev: v0.16.0
hooks:
- id: ruff
name: ruff check
Expand Down
2 changes: 1 addition & 1 deletion 01-hello/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from workers import WorkerEntrypoint, Response
from workers import Response, WorkerEntrypoint


class Default(WorkerEntrypoint):
Expand Down
2 changes: 1 addition & 1 deletion 02-binding/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from workers import WorkerEntrypoint, Response
from workers import Response, WorkerEntrypoint


class Default(WorkerEntrypoint):
Expand Down
2 changes: 1 addition & 1 deletion 04-query-d1/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from workers import WorkerEntrypoint, Response
from workers import Response, WorkerEntrypoint


class Default(WorkerEntrypoint):
Expand Down
2 changes: 1 addition & 1 deletion 05-langchain/src/worker.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
from workers import WorkerEntrypoint, Response
from langchain_core.prompts import PromptTemplate
from langchain_openai import OpenAI
from workers import Response, WorkerEntrypoint


class Default(WorkerEntrypoint):
Expand Down
6 changes: 3 additions & 3 deletions 07-durable-objects/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
from workers import WorkerEntrypoint, Response, DurableObject
from pyodide.ffi import to_js
from urllib.parse import urlparse

from pyodide.ffi import to_js
from workers import DurableObject, Response, WorkerEntrypoint


class List(DurableObject):
async def get_messages(self):
Expand All @@ -12,7 +13,6 @@ async def add_message(self, message):
messages = await self.get_messages()
messages.append(message)
await self.ctx.storage.put("messages", to_js(messages))
return


class Default(WorkerEntrypoint):
Expand Down
2 changes: 1 addition & 1 deletion 08-cron/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from workers import WorkerEntrypoint, Response
from workers import Response, WorkerEntrypoint


class Default(WorkerEntrypoint):
Expand Down
2 changes: 1 addition & 1 deletion 09-workers-ai/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
from workers import WorkerEntrypoint, Response
from workers import Response, WorkerEntrypoint


class Default(WorkerEntrypoint):
Expand Down
5 changes: 3 additions & 2 deletions 10-workflows/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,8 @@
from workers import WorkerEntrypoint, Response, WorkflowEntrypoint
from urllib.parse import urlparse
import asyncio
import random
from urllib.parse import urlparse

from workers import Response, WorkerEntrypoint, WorkflowEntrypoint


class DAGWorkflow(WorkflowEntrypoint):
Expand Down
6 changes: 3 additions & 3 deletions 11-opengraph/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
from workers import WorkerEntrypoint, Request, fetch
from js import HTMLRewriter
from urllib.parse import urlparse
from html import escape
from urllib.parse import urlparse

from js import HTMLRewriter
from pyodide.ffi import create_proxy
from workers import Request, WorkerEntrypoint, fetch


class MetaTagInjector:
Expand Down
12 changes: 6 additions & 6 deletions 12-image-gen/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
from workers import WorkerEntrypoint, Response, Request
from PIL import Image, ImageDraw, ImageFont
from io import BytesIO
from urllib.parse import urlparse, parse_qs
import random
from io import BytesIO
from pathlib import Path
from urllib.parse import parse_qs, urlparse

from PIL import Image, ImageDraw, ImageFont
from pyodide.ffi import to_js
from workers import Request, Response, WorkerEntrypoint


class Default(WorkerEntrypoint):
Expand Down Expand Up @@ -65,9 +65,9 @@ def generate_gradient(self, params: dict) -> Response:
color2 = params.get("color2", [None])[0]

if not color1:
color1 = "#{:06x}".format(random.randint(0, 0xFFFFFF))
color1 = f"#{random.randint(0, 0xFFFFFF):06x}"
if not color2:
color2 = "#{:06x}".format(random.randint(0, 0xFFFFFF))
color2 = f"#{random.randint(0, 0xFFFFFF):06x}"

# Convert hex colors to RGB tuples
r1, g1, b1 = self.hex_to_rgb(color1)
Expand Down
4 changes: 2 additions & 2 deletions 13-js-api-pygments/py/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
from workers import WorkerEntrypoint, Response, Request
from pygments import highlight
from pygments.lexers import get_lexer_by_name, guess_lexer
from pygments.formatters import HtmlFormatter
from pygments.lexers import get_lexer_by_name, guess_lexer
from pygments.util import ClassNotFound
from workers import Request, Response, WorkerEntrypoint


class Default(WorkerEntrypoint):
Expand Down
7 changes: 4 additions & 3 deletions 14-websocket-stream-consumer/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,10 +1,11 @@
from workers import WorkerEntrypoint, Response, DurableObject
import js
import json
import time
from pyodide.ffi import create_proxy
from urllib.parse import urlparse

import js
from pyodide.ffi import create_proxy
from workers import DurableObject, Response, WorkerEntrypoint


class BlueskyFirehoseConsumer(DurableObject):
"""Durable Object that maintains a persistent WebSocket connection to Bluesky Jetstream."""
Expand Down
11 changes: 6 additions & 5 deletions 15-chatroom/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,9 +1,10 @@
from workers import WorkerEntrypoint, Response, DurableObject
from pathlib import Path
from js import WebSocketPair
import json
from datetime import UTC, datetime
from pathlib import Path
from urllib.parse import urlparse
from datetime import datetime, timezone

from js import WebSocketPair
from workers import DurableObject, Response, WorkerEntrypoint


class Chatroom(DurableObject):
Expand Down Expand Up @@ -95,7 +96,7 @@ def broadcast(self, message):

def get_timestamp(self):
"""Get current timestamp in ISO format."""
return datetime.now(timezone.utc).isoformat()
return datetime.now(UTC).isoformat()


class Default(WorkerEntrypoint):
Expand Down
2 changes: 1 addition & 1 deletion 17-dynamic-py-py/src/entry.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
from pyodide.ffi import create_proxy, to_js
from js import Object
from pyodide.ffi import create_proxy, to_js
from workers import WorkerEntrypoint

# The source code of the dynamically-loaded Python Worker. In a real
Expand Down
8 changes: 4 additions & 4 deletions tests/conftest.py
Original file line number Diff line number Diff line change
@@ -1,12 +1,12 @@
import os
import subprocess
import time
import socket
import subprocess
import sys
import pytest
import time
from contextlib import contextmanager
from pathlib import Path

from contextlib import contextmanager
import pytest

REPO_ROOT = Path(__file__).parents[1]

Expand Down
5 changes: 3 additions & 2 deletions tests/test_examples.py
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
import requests
import pytest
import subprocess

import pytest
import requests
from conftest import REPO_ROOT


Expand Down
Loading