class_docstr: Class for sending callbacks to DagProcessor using pipe.
  
  It is used when DagProcessor is not executed in standalone mode.
class_docstr_tok: ["Class","for","sending","callbacks","to","DagProcessor","using","pipe",".","It","is","used","when","DagProcessor","is","not","executed","in","standalone","mode","."]
code: def __init__(
      self, get_sink_pipe: Callable[[], MultiprocessingConnection]
  ):
      self._get_sink_pipe = get_sink_pipe
  
imports: from __future__ import annotations
  from typing import TYPE_CHECKING, Callable
  from airflow.callbacks.base_callback_sink import BaseCallbackSink
label_desc: Use image node_id 1 to create a new PipeCallbackSink object from inherited base classes: BaseCallbackSink with example: obj = PipeCallbackSink(get_sink_pipe)