fix example, change warning log to debug

Author: soapun

taskiq/instrumentation.py

@@ -17,15 +17,12 @@
 
     broker = InMemoryBroker()
 
-    @broker.on_event(TaskiqEvents.WORKER_STARTUP)
-    async def startup(state: TaskiqState) -> None:
-        TaskiqInstrumentor().instrument()
-
     @broker.task
     async def add(x, y):
         return x + y
 
     async def main():
+        TaskiqInstrumentor().instrument()
         await broker.startup()
         await my_task.kiq(1, 2)
         await broker.shutdown()

taskiq/middlewares/opentelemetry_middleware.py

@@ -191,7 +191,7 @@ def post_send(self, message: TaskiqMessage) -> None:
         ctx = retrieve_context(message, is_publish=True)
 
         if ctx is None:
-            logger.warning("no existing span found for task_id=%s", message.task_id)
+            logger.debug("no existing span found for task_id=%s", message.task_id)
             return
 
         _, activation, _ = ctx