-
Notifications
You must be signed in to change notification settings - Fork 1
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Faststream docs #403
base: fastapi-poc
Are you sure you want to change the base?
Faststream docs #403
Conversation
❌ 10 Tests Failed:
View the top 3 failed tests by shortest run time
To view individual test run time comparison to the main branch, go to the Test Analytics Dashboard |
@@ -191,7 +191,9 @@ class GXAgent: | |||
_PYPI_GX_AGENT_PACKAGE_NAME = "great_expectations_cloud" | |||
_PYPI_GREAT_EXPECTATIONS_PACKAGE_NAME = "great_expectations" | |||
|
|||
def __init__(self: Self): | |||
def __init__(self: Self, app: FastStream, broker: RabbitBroker) -> None: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is a breaking change for runner.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Just discovered the Faststream
app exposes a .broker
attribute, so we don't need to inject app
+ broker
, app
by itself is enough.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@TrangPham
Also, I think I see how to make this not breaking, but I didn't have a chance to implement it today.
I'll try to push it in the morning.
asyncapi.yaml
Outdated
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
To see what these docs would look like live, go to the asyncapi studio and paste them into the editor.
Generate AsyncAPI docs from the Faststream App.