opensource/cloudbeaver
3
0
Fork 0
mirror of https://github.com/dbeaver/cloudbeaver.git synced 2026-10-24 23:05:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(core): async task API

Browse Source 
CB-197
This commit is contained in:
Wroud
2020-08-05 12:15:26 +03:00
parent c7f403bb50
commit fb597af045
8 changed files with 82 additions and 234 deletions
Download Patch File Download Diff File Expand all files Collapse all files
webapp/packages/plugin-data-export/src/ExportFromContainerProcess.ts
+8 -4
View File
@@ -40,7 +40,7 @@ export class ExportFromContainerProcess extends Deferred<string> {
containerNodePath,
parameters,
});
this.applyResult(taskInfo);
await this.applyResult(taskInfo);
this.taskId = taskInfo.id;
if (this.getState() === EDeferredState.CANCELLING) {
await this.cancelAsync(this.taskId);
@@ -80,8 +80,11 @@ export class ExportFromContainerProcess extends Deferred<string> {
}
// run the first check immediately because usually the query execution is fast
try {
const { taskInfo } = await this.graphQLService.gql.asyncExportTaskStatus({ taskId: this.taskId });
this.applyResult(taskInfo);
const { taskInfo } = await this.graphQLService.gql.getAsyncTaskInfo({
taskId: this.taskId,
removeOnFinish: false,
});
await this.applyResult(taskInfo);
if (this.isFinished) {
return;
}
@@ -111,7 +114,7 @@ export class ExportFromContainerProcess extends Deferred<string> {
}
}
private applyResult(taskInfo: AsyncTaskInfo): void {
private async applyResult(taskInfo: AsyncTaskInfo) {
// task is running
if (taskInfo.running) {
return;
@@ -128,6 +131,7 @@ export class ExportFromContainerProcess extends Deferred<string> {
}
// task execution successful
this.toResolved(taskInfo.taskResult);
await this.graphQLService.gql.getAsyncTaskInfo({ taskId: taskInfo.id, removeOnFinish: true });
}
private onError(error: Error, status?: string) {