Simplify examples (#169)

inngest · Sep 30, 2024 · 38accc1 · 38accc1
1 parent 1d1002c
commit 38accc1
Show file tree

Hide file tree

Showing 34 changed files with 113 additions and 526 deletions.
diff --git a/examples/digital_ocean/app.py b/examples/digital_ocean/app.py
@@ -1,12 +1,12 @@
-from src.inngest import inngest_client
+from src.inngest.client import inngest_client
+from src.inngest.functions import hello
 
 import inngest.digital_ocean
-from examples import functions
 from inngest.experimental.digital_ocean_simulator import DigitalOceanSimulator
 
 main = inngest.digital_ocean.serve(
     inngest_client,
-    functions.create_sync_functions(inngest_client),
+    [hello],
 )
 
 # This should not be used in production. It's just for locally running

diff --git a/examples/digital_ocean/src/inngest/__init__.py b/examples/digital_ocean/src/inngest/__init__.py
@@ -1,3 +0,0 @@
-from .client import inngest_client
-
-__all__ = ["inngest_client"]

diff --git a/examples/digital_ocean/src/inngest/functions.py b/examples/digital_ocean/src/inngest/functions.py
@@ -0,0 +1,14 @@
+import inngest
+
+from .client import inngest_client
+
+
+@inngest_client.create_function(
+    fn_id="hello-world",
+    trigger=inngest.TriggerEvent(event="say-hello"),
+)
+def hello(
+    ctx: inngest.Context,
+    step: inngest.StepSync,
+) -> str:
+    return "Hello world!"
diff --git a/examples/django/inngest_django/functions.py b/examples/django/inngest_django/functions.py
@@ -0,0 +1,14 @@
+import inngest
+
+from .inngest_client import inngest_client
+
+
+@inngest_client.create_function(
+    fn_id="hello-world",
+    trigger=inngest.TriggerEvent(event="say-hello"),
+)
+def hello(
+    ctx: inngest.Context,
+    step: inngest.StepSync,
+) -> str:
+    return "Hello world!"
diff --git a/examples/django/inngest_django/urls.py b/examples/django/inngest_django/urls.py
@@ -2,14 +2,14 @@
 from django.urls import path
 
 import inngest.django
-from examples import functions
 
+from .functions import hello
 from .inngest_client import inngest_client
 
 urlpatterns = [
     path("admin/", admin.site.urls),
     inngest.django.serve(
         inngest_client,
-        functions.create_sync_functions(inngest_client),
+        [hello],
     ),
 ]
diff --git a/examples/fast_api/app.py b/examples/fast_api/app.py
@@ -1,14 +1,14 @@
 import fastapi
-from src.inngest import inngest_client
+from src.inngest.client import inngest_client
+from src.inngest.functions import hello
 
 import inngest.fast_api
-from examples import functions
 
 app = fastapi.FastAPI()
 
 
 inngest.fast_api.serve(
     app,
     inngest_client,
-    functions.create_async_functions(inngest_client),
+    [hello],
 )
diff --git a/examples/fast_api/src/inngest/__init__.py b/examples/fast_api/src/inngest/__init__.py
@@ -1,3 +0,0 @@
-from .client import inngest_client
-
-__all__ = ["inngest_client"]

diff --git a/examples/fast_api/src/inngest/client.py b/examples/fast_api/src/inngest/client.py
@@ -2,8 +2,7 @@
 
 import inngest
 
-logger = logging.getLogger(__name__)
-logger.addHandler(logging.StreamHandler())
+logger = logging.getLogger("uvicorn.inngest")
 logger.setLevel(logging.DEBUG)
 
 inngest_client = inngest.Inngest(app_id="fast_api_example", logger=logger)
diff --git a/examples/fast_api/src/inngest/functions.py b/examples/fast_api/src/inngest/functions.py
@@ -0,0 +1,14 @@
+import inngest
+
+from .client import inngest_client
+
+
+@inngest_client.create_function(
+    fn_id="hello-world",
+    trigger=inngest.TriggerEvent(event="say-hello"),
+)
+async def hello(
+    ctx: inngest.Context,
+    step: inngest.Step,
+) -> str:
+    return "Hello world!"
diff --git a/examples/flask/app.py b/examples/flask/app.py
@@ -1,15 +1,13 @@
-import flask
-from src.inngest import inngest_client
+from src.flask import app
+from src.inngest.client import inngest_client
+from src.inngest.functions import hello
 
 import inngest.flask
-from examples import functions
-
-app = flask.Flask(__name__)
-
 
 inngest.flask.serve(
     app,
     inngest_client,
-    functions.create_sync_functions(inngest_client),
+    [hello],
 )
+
 app.run(port=8000)
diff --git a/examples/flask/src/flask.py b/examples/flask/src/flask.py
@@ -0,0 +1,3 @@
+import flask
+
+app = flask.Flask("my-app")
diff --git a/examples/flask/src/inngest/__init__.py b/examples/flask/src/inngest/__init__.py
@@ -1,3 +0,0 @@
-from .client import inngest_client
-
-__all__ = ["inngest_client"]

diff --git a/examples/flask/src/inngest/client.py b/examples/flask/src/inngest/client.py
@@ -1,9 +1,9 @@
 import logging
 
 import inngest
+from src.flask import app
 
-logger = logging.getLogger(__name__)
-logger.addHandler(logging.StreamHandler())
+logger = logging.getLogger(f"{app.logger.name}.inngest")
 logger.setLevel(logging.DEBUG)
 
 inngest_client = inngest.Inngest(app_id="flask_example", logger=logger)
diff --git a/examples/flask/src/inngest/functions.py b/examples/flask/src/inngest/functions.py
@@ -0,0 +1,14 @@
+import inngest
+
+from .client import inngest_client
+
+
+@inngest_client.create_function(
+    fn_id="hello-world",
+    trigger=inngest.TriggerEvent(event="say-hello"),
+)
+def hello(
+    ctx: inngest.Context,
+    step: inngest.StepSync,
+) -> str:
+    return "Hello world!"
diff --git a/examples/functions/__init__.py b/examples/functions/__init__.py
diff --git a/examples/functions/batch.py b/examples/functions/batch.py
diff --git a/examples/functions/cancel.py b/examples/functions/cancel.py
diff --git a/examples/functions/cron.py b/examples/functions/cron.py
diff --git a/examples/functions/debounce.py b/examples/functions/debounce.py
diff --git a/examples/functions/duplicate_step_name.py b/examples/functions/duplicate_step_name.py
diff --git a/examples/functions/error_step.py b/examples/functions/error_step.py
Original file line number	Diff line number	Diff line change
		@@ -1,3 +0,0 @@
		from .client import inngest_client

		__all__ = ["inngest_client"]