_Middleware

Helper wrapper class to make the middleware easily observable by open telemetry instrumentation.

Index

Methods

• __init__
• action
• cleanup

Methods

__init__

• __init__(middleware, input_context): None

• Parameters

  • middleware: Callable[[TCrawlingContext], AsyncGenerator[TMiddlewareCrawlingContext, Exception | None]]

  • input_context: TCrawlingContext

  Returns None

action

• async action(): TMiddlewareCrawlingContext

• Returns TMiddlewareCrawlingContext

cleanup

• async cleanup(final_consumer_exception): None

• Parameters

  • final_consumer_exception: Exception | None

  Returns None