File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1994,8 +1994,7 @@ export async function startAgentBusServer(
19941994 }
19951995 if ( req . method === 'POST' && req . url === '/v1/batch' ) {
19961996 const body = JSON . parse ( await readBody ( req ) ) as
1997- | { items ?: AgentBusEvent [ ] ; enqueue ?: boolean }
1998- | AgentBusEvent [ ] ;
1997+ { items ?: AgentBusEvent [ ] ; enqueue ?: boolean } | AgentBusEvent [ ] ;
19991998 const items = Array . isArray ( body ) ? body : body . items || [ ] ;
20001999 const enqueue = ! Array . isArray ( body ) && body . enqueue === true ;
20012000 const rows = await runBatch ( items , { ...options , enqueue } ) ;
@@ -2013,8 +2012,7 @@ export async function startAgentBusServer(
20132012 }
20142013 if ( req . method === 'POST' && req . url === '/v1/fanout' ) {
20152014 const body = JSON . parse ( await readBody ( req ) ) as
2016- | { items ?: AgentBusEvent [ ] ; enqueue ?: boolean ; concurrency ?: number }
2017- | AgentBusEvent [ ] ;
2015+ { items ?: AgentBusEvent [ ] ; enqueue ?: boolean ; concurrency ?: number } | AgentBusEvent [ ] ;
20182016 const items = Array . isArray ( body ) ? body : body . items || [ ] ;
20192017 const enqueue = ! Array . isArray ( body ) && body . enqueue === true ;
20202018 const concurrency = ! Array . isArray ( body ) ? Number ( body . concurrency || 4 ) : 4 ;
Original file line number Diff line number Diff line change @@ -115,8 +115,7 @@ export type GovernedTaskRun = z.infer<typeof GovernedTaskRunSchema>;
115115export type TaskFieldBasis = z . infer < typeof TaskFieldBasisSchema > ;
116116
117117export type TaskRunParseResult =
118- | { ok : true ; data : GovernedTaskRun }
119- | { ok : false ; errors : string [ ] ; raw : unknown } ;
118+ { ok : true ; data : GovernedTaskRun } | { ok : false ; errors : string [ ] ; raw : unknown } ;
120119
121120export interface TaskApiClientOptions {
122121 baseUrl ?: string ;
You can’t perform that action at this time.
0 commit comments