mirror of
https://github.com/sasjs/adapter.git
synced 2026-01-10 13:50:05 +00:00
fix(job-execution): fetch log when webout is not available
This commit is contained in:
@@ -14,9 +14,10 @@ import {
|
|||||||
Context,
|
Context,
|
||||||
Folder,
|
Folder,
|
||||||
CsrfToken,
|
CsrfToken,
|
||||||
EditContextInput
|
EditContextInput,
|
||||||
|
ErrorResponse,
|
||||||
|
JobDefinition
|
||||||
} from './types'
|
} from './types'
|
||||||
import { JobDefinition } from './types/JobDefinition'
|
|
||||||
import { formatDataForRequest } from './utils/formatDataForRequest'
|
import { formatDataForRequest } from './utils/formatDataForRequest'
|
||||||
import { SessionManager } from './SessionManager'
|
import { SessionManager } from './SessionManager'
|
||||||
|
|
||||||
@@ -540,9 +541,30 @@ export class SASViyaApiClient {
|
|||||||
`${this.serverUrl}${resultLink}`,
|
`${this.serverUrl}${resultLink}`,
|
||||||
{ headers },
|
{ headers },
|
||||||
'text'
|
'text'
|
||||||
).catch((e) => ({
|
).catch(async (e) => {
|
||||||
result: JSON.stringify(e)
|
if (e && e.status === 404) {
|
||||||
}))
|
if (logLink) {
|
||||||
|
log = await this.request<any>(
|
||||||
|
`${this.serverUrl}${logLink.href}/content?limit=10000`,
|
||||||
|
{
|
||||||
|
headers
|
||||||
|
}
|
||||||
|
).then((res: any) =>
|
||||||
|
res.result.items.map((i: any) => i.line).join('\n')
|
||||||
|
)
|
||||||
|
|
||||||
|
return Promise.reject(
|
||||||
|
new ErrorResponse('Job execution failed', {
|
||||||
|
status: 500,
|
||||||
|
body: log
|
||||||
|
})
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return {
|
||||||
|
result: JSON.stringify(e)
|
||||||
|
}
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
await this.sessionManager.clearSession(executionSessionId, accessToken)
|
await this.sessionManager.clearSession(executionSessionId, accessToken)
|
||||||
|
|||||||
Reference in New Issue
Block a user