def on_reply()

in message_flow/sagas/orchestration_simple_dsl/invoke_participant_step_builder.py [0:0]

• 2 lines of code
• 1 McCabe index (conditional complexity)

    def on_reply(
        self, reply_class: Type[T], reply_handler: Callable[[Data, T], None]