parameters: (self, **kwargs)
docstring: This Pipeline received an asynchronous callback request.
docstring_summary: This Pipeline received an asynchronous callback request.
docstring_tokens: This Pipeline received an asynchronous callback request .
function: def callback(self, **kwargs):
      """This Pipeline received an asynchronous callback request."""
      raise NotImplementedError(
          'Must implement "callback" in Pipeline sub-class.')
function_tokens: def callback ( self , * * kwargs ) : raise NotImplementedError ( 'Must implement "callback" in Pipeline sub-class.' )