Simplify framework examples

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

examples/digital_ocean/src/inngest/__init__.py

@@ -1,3 +0,0 @@
-from .client import inngest_client
-
-__all__ = ["inngest_client"]

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!"

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!"

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],
     ),
 ]

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],
 )

examples/fast_api/src/inngest/__init__.py

@@ -1,3 +0,0 @@
-from .client import inngest_client
-
-__all__ = ["inngest_client"]

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)

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!"

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)

examples/flask/src/flask.py

@@ -0,0 +1,3 @@
+import flask
+
+app = flask.Flask("my-app")

examples/flask/src/inngest/__init__.py

@@ -1,3 +0,0 @@
-from .client import inngest_client
-
-__all__ = ["inngest_client"]

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)

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!"