dev/reformat

This commit is contained in:
jyong 2025-09-16 19:13:22 +08:00
parent 5133623d42
commit 8cbfaa2c03
2 changed files with 3 additions and 3 deletions

View File

@ -67,7 +67,7 @@ class DatasourceNodeRunApi(DatasetApiResource):
"""Resource for datasource node run."""
@service_api_ns.doc(shortcut="pipeline_datasource_node_run")
@service_api_ns.doc(description="Run a atasource node for a rag pipeline")
@service_api_ns.doc(description="Run a datasource node for a rag pipeline")
@service_api_ns.doc(
path={
"dataset_id": "Dataset ID",

View File

@ -32,9 +32,9 @@ class PipelineGenerateService:
"""
try:
workflow = cls._get_workflow(pipeline, invoke_from)
if args.get("original_document_id"):
if original_document_id := args.get("original_document_id"):
# update document status to waiting
cls.update_document_status(args.get("original_document_id", ""))
cls.update_document_status(original_document_id)
return PipelineGenerator.convert_to_event_stream(
PipelineGenerator().generate(
pipeline=pipeline,