Searched refs:pipeline_func (Results 1 – 1 of 1) sorted by relevance
2047 pipeline_func = pipeline_func_class.from_id(2072 caller_output = pipeline_func.outputs2074 if (abort_signal and pipeline_func.async and2076 and not pipeline_func.try_cancel()):2079 pipeline_func, pipeline_key.name())2084 pipeline_func._finalized_internal(2092 pipeline_func, pipeline_key.name(), retry_message)2100 logging.debug('Marking as aborted %s#%s', pipeline_func,2139 pipeline_func.async):2143 result = pipeline_func._run_internal([all …]