MCPcopy Create free account
hub / github.com/baidu/bigflow / run

Method run

bigflow_python/python/bigflow/pipeline/pipeline_base.py:262–269  ·  view source on GitHub ↗

立刻运行Pipeline并等待结束 Raises: BigflowRuntimeException: 若运行期出错抛出此异常

(self)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 15

getMethod · 0.45
uv.pyFile · 0.45
word_cnt.pyFile · 0.45
test_text_fileMethod · 0.45
test_text_file_syncMethod · 0.45
test_schema_text_fileMethod · 0.45
test_text_file_sortMethod · 0.45
test_sequence_fileMethod · 0.45
test_sequence_file_syncMethod · 0.45
test_sequence_file_invalidMethod · 0.45
test_sequence_file_serdeMethod · 0.45
wildcard_caseMethod · 0.45

Calls

no outgoing calls

Tested by 15

test_text_fileMethod · 0.36
test_text_file_syncMethod · 0.36
test_schema_text_fileMethod · 0.36
test_text_file_sortMethod · 0.36
test_sequence_fileMethod · 0.36
test_sequence_file_syncMethod · 0.36
test_sequence_file_invalidMethod · 0.36
test_sequence_file_serdeMethod · 0.36
wildcard_caseMethod · 0.36
test_commitMethod · 0.36
test_concurrencyMethod · 0.36
test_write_binary_set_by_userMethod · 0.36