@@ -568,6 +568,7 @@ async def build_public_tmp(
568
568
flow_name : str | None = None ,
569
569
request : Request ,
570
570
queue_service : Annotated [JobQueueService , Depends (get_queue_service )],
571
+ event_delivery : EventDeliveryType = EventDeliveryType .POLLING ,
571
572
):
572
573
"""Build a public flow without requiring authentication.
573
574
@@ -595,6 +596,7 @@ async def build_public_tmp(
595
596
flow_name: Optional name for the flow
596
597
request: FastAPI request object (needed for cookie access)
597
598
queue_service: Queue service for job management
599
+ event_delivery: Optional event delivery type - default is streaming
598
600
599
601
Returns:
600
602
Dict with job_id that can be used to poll for build status
@@ -623,4 +625,10 @@ async def build_public_tmp(
623
625
if isinstance (exc , HTTPException ):
624
626
raise
625
627
raise HTTPException (status_code = 500 , detail = str (exc )) from exc
626
- return {"job_id" : job_id }
628
+ if event_delivery != EventDeliveryType .DIRECT :
629
+ return {"job_id" : job_id }
630
+ return await get_flow_events_response (
631
+ job_id = job_id ,
632
+ queue_service = queue_service ,
633
+ event_delivery = event_delivery ,
634
+ )
0 commit comments