python sdk cloudevents 2.*

Author: gauron99

e2e/testdata/templates-userdeps/python/http/pyproject.toml

@@ -1,7 +1,7 @@
 [project]
 name = "function"
 version = "0.1.0"
-requires-python = ">=3.9"
+requires-python = ">=3.10"
 license = "MIT"
 
 [build-system]

e2e/testdata/templates/python/http/pyproject.toml

@@ -2,7 +2,7 @@
 name = "function"
 description = ""
 version = "0.1.0"
-requires-python = ">=3.9"
+requires-python = ">=3.10"
 readme = "README.md"
 license = "MIT"
 dependencies = [

generate/zz_filesystem_generated.go

@@ -1,6 +1,6 @@
 # Function
 import logging
-from cloudevents.http import CloudEvent
+from cloudevents.core.v1.event import CloudEvent
 
 
 def new():
@@ -33,16 +33,16 @@ async def handle(self, scope, receive, send):
         request = scope["event"]
 
         # 2) Create a new CloudEvent as response with "OK" as data
-        response = CloudEvent({
-            "type": "function.response",
-            "source": "function",
-            "id": f"response-{request.get('id', 'unknown')}"
-        })
+        response = CloudEvent(
+            attributes={
+                "type": "function.response",
+                "source": "function",
+                "id": f"response-{request.get_id() or 'unknown'}"
+            },
+            data={"message": "OK"}
+        )
 
-        # 3) Set the response's data field to {"message": "OK"}
-        response.data = {"message": "OK"}
-
-        # 4) Send the response CloudEvent
+        # 3) Send the response CloudEvent
         # The 'send' method is already decorated with CloudEvent middleware
         await send(response)
 

templates/python/cloudevents/function/func.py

@@ -2,12 +2,12 @@
 name = "function"
 description = ""
 version = "0.1.0"
-requires-python = ">=3.9"
+requires-python = ">=3.10"
 readme = "README.md"
 license = "MIT"
 dependencies = [
   "httpx",
-  "cloudevents>=1.11,<2",
+  "cloudevents>=2,<3",
   "pytest",
   "pytest-asyncio"
 ]

templates/python/cloudevents/pyproject.toml

@@ -10,7 +10,7 @@
 import json
 import asyncio
 import pytest
-from cloudevents.http import CloudEvent
+from cloudevents.core.v1.event import CloudEvent
 from function import new
 
 
@@ -25,7 +25,7 @@ async def test_func():
         "source": "https://example.com/event-producer",
     }
     data = {"message": "test message"}
-    event = CloudEvent(attributes, data)
+    event = CloudEvent(attributes=attributes, data=data)
 
     invoked = False  # Flag indicating send method was invoked
 
@@ -40,7 +40,7 @@ async def send(e):
 
         # Ensure it returns {"message": "OK"} as data
         expected = {"message": "OK"}
-        assert e.data == expected, f"Expected data {expected}, got {e.data}"
+        assert e.get_data() == expected, f"Expected data {expected}, got {e.get_data()}"
 
     # Invoke the Function
     scope = {"event": event}  # Add the CloudEvent to the scope

templates/python/cloudevents/tests/test_func.py

@@ -2,7 +2,7 @@
 name = "function"
 description = ""
 version = "0.1.0"
-requires-python = ">=3.9"
+requires-python = ">=3.10"
 readme = "README.md"
 license = "MIT"
 dependencies = [

templates/python/http/pyproject.toml

@@ -2,11 +2,11 @@
 name = "service"
 description = "an autogenerated service which runs a Function"
 version = "0.1.0"
-requires-python = ">=3.9"
+requires-python = ">=3.10"
 readme = "README.md"
 license = "MIT"
 dependencies = [
-    "func-python==0.7.0",
+    "func-python==0.8.0",
     "function @ {root:uri}/f"
 ]
 authors = [

templates/python/scaffolding/instanced-cloudevents/pyproject.toml

@@ -2,11 +2,11 @@
 name = "service"
 description = "an autogenerated service which runs a Function"
 version = "0.1.0"
-requires-python = ">=3.9"
+requires-python = ">=3.10"
 readme = "README.md"
 license = "MIT"
 dependencies = [
-    "func-python==0.7.0",
+    "func-python==0.8.0",
     "function @ {root:uri}/f"
 ]
 authors = [