File tree Expand file tree Collapse file tree
tests/integ_tests/workflow_tests Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -258,6 +258,13 @@ async fn nexus_async(
258258 // Get the next start request
259259 nt = core_worker. poll_nexus_task ( ) . await . unwrap ( ) . unwrap_task ( ) ;
260260 }
261+ let links = start_req
262+ . links
263+ . iter ( )
264+ . map ( workflow_event_link_from_nexus)
265+ . collect :: < Result < Vec < _ > , _ > > ( )
266+ . unwrap ( ) ;
267+
261268 // Start the workflow which will act like the nexus handler and complete the async
262269 // operation
263270 submitter
@@ -266,18 +273,15 @@ async fn nexus_async(
266273 "async_completer" ,
267274 vec ! [ ] ,
268275 WorkflowOptions {
269- links : start_req
270- . links
271- . iter ( )
272- . map ( workflow_event_link_from_nexus)
273- . collect :: < Result < Vec < _ > , _ > > ( )
274- . unwrap ( ) ,
275276 completion_callbacks : vec ! [ Callback {
276277 variant: Some ( callback:: Variant :: Nexus ( callback:: Nexus {
277278 url: start_req. callback,
278279 header: start_req. callback_header,
279280 } ) ) ,
281+ links: links. clone( ) ,
280282 } ] ,
283+ // Also send links in the root of the workflow options for older servers.
284+ links,
281285 ..Default :: default ( )
282286 } ,
283287 )
You can’t perform that action at this time.
0 commit comments