RuntimeError with aiohttp

[alexreznikoff]

RuntimeError with aiohttp

[alexreznikoff]

Hello @artas728
Thank you, it works

[artas728]

Hello @alexreznikoff
The problem is in the conflict related to sentry behavior (I have not worked with sentry before and do not know how it works). I ran your code without sentry and it works well. I would recommend trying to run sentry as a panini task:

from aiohttp import web
from panini import app as panini_app
import sentry_sdk
import settings

app = panini_app.App(
    service_name='nats-microservice-that-also-http',
    host='127.0.0.1',
    port=4222,
)
app.setup_web_server(port=5000)

@app.task()
def start_sentry():
    sentry_sdk.init(settings.SENTRY_SDK)

@app.listen("some.subject")
async def stream_listener(msg):
    print(f"event {msg.data} from {msg.subject} has been processed")


@app.http.get("/status")
async def web_endpoint_listener(request):
    return web.json_response({"status": "ok"})

if __name__ == "__main__":
    app.start()

Let me know if it works.