def process_argspec_fn(self):
    raise NotImplementedError
Called by BlockingChannel instances to request a call to their
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/transforms/ptransform.py/PTransformWithSideInputs.process_argspec_fn--crossover with--dataset/ETHPy150Open pika/pika/pika/adapters/blocking_connection.py/BlockingConnection._request_channel_dispatch