fix: correct AsyncAPI 2.6 operations

airtai · Nov 20, 2024 · 921ead8 · 921ead8
1 parent f22c2d5
commit 921ead8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 13 deletions.
diff --git a/faststream/specification/asyncapi/v2_6_0/schema/channels.py b/faststream/specification/asyncapi/v2_6_0/schema/channels.py
@@ -48,8 +48,8 @@ def from_sub(cls, subscriber: SubscriberSpec) -> Self:
             description=subscriber.description,
             servers=None,
             bindings=ChannelBinding.from_sub(subscriber.bindings),
-            subscribe=Operation.from_sub(subscriber.operation),
-            publish=None,
+            subscribe=None,
+            publish=Operation.from_sub(subscriber.operation),
         )
 
     @classmethod
@@ -58,6 +58,6 @@ def from_pub(cls, publisher: PublisherSpec) -> Self:
             description=publisher.description,
             servers=None,
             bindings=ChannelBinding.from_pub(publisher.bindings),
-            subscribe=None,
-            publish=Operation.from_pub(publisher.operation),
+            subscribe=Operation.from_pub(publisher.operation),
+            publish=None,
         )
diff --git a/serve.py b/serve.py