def __call_internal__(self, *args, **kwargs):
        self.source = self._source_function(*args, **kwargs)
        kwargs.pop('name', None)
        self.store_kwargs(kwargs)
        # Copy the pipeline so as not to modify it for the next call
        self.pipeline = self._pipeline[:]
        if tools._has_scalar_data(self.source):
            self.pipeline.pop(0)
        return self.build_pipeline()
Wrapped by CallWithRetryAsync in order to support retry.
dataset/ETHPy150Open enthought/mayavi/mayavi/tools/helper_functions.py/Flow.__call_internal__--crossover with--dataset/ETHPy150Open viewfinderco/viewfinder/backend/storage/async_s3.py/AsyncS3Connection._make_request