support for asyncComplete flag for http task

Author: DmitryBorisov-sm

src/common/types.ts

@@ -119,6 +119,7 @@ export interface HttpTaskDef extends CommonTaskDef {
     http_request: HttpInputParameters;
   };
   type: TaskType.HTTP;
+  asyncComplete?: boolean;
 }
 
 export interface InlineTaskInputParameters {

src/core/__test__/executor.test.ts

@@ -7,6 +7,8 @@ import {MetadataClient} from "../metadataClient";
 import {TestUtil} from "./utils/test-util";
 import {TaskResultStatusEnum} from "../../common/open-api/models/TaskResultStatusEnum";
 import {SignalResponse} from "../../common/open-api/models/SignalResponse";
+import { httpTask } from "../sdk";
+import { TaskClient } from "../taskClient";
 
 describe("Executor", () => {
   const clientPromise = orkesConductorClient({ useEnvVars: true });
@@ -111,6 +113,42 @@ describe("Executor", () => {
     const executionDetails = await executor.getWorkflow(executionId!, true);
     expect(executionDetails.idempotencyKey).toEqual(idempotencyKey);
   });
+
+  test("Should run workflow with http task with asyncComplete true", async () => {
+    const client = await clientPromise;
+    const executor = new WorkflowExecutor(client);
+  
+    await executor.registerWorkflow(true, {
+      name: "test_jssdk_workflow_with_http_task_with_asyncComplete_true",
+      version: 1,
+      ownerEmail: "developers@orkes.io",
+      tasks: [httpTask("test_jssdk_http_task_with_asyncComplete_true", { uri: "http://www.yahoo.com", method: "GET" }, true)],
+      inputParameters: [],
+      outputParameters: {},
+      timeoutSeconds: 300,
+    });
+  
+    const executionId = await executor.startWorkflow({
+      name: "test_jssdk_workflow_with_http_task_with_asyncComplete_true",
+      input: {},
+      version: 1,
+    });
+  
+    await new Promise(resolve => setTimeout(resolve, 2000));
+    const workflowStatusBefore = await executor.getWorkflow(executionId, true);
+  
+    expect(workflowStatusBefore.status).toEqual("RUNNING");
+    expect(workflowStatusBefore.tasks?.[0]?.status).toEqual("IN_PROGRESS");
+  
+    const taskClient = new TaskClient(client);
+    taskClient.updateTaskResult(executionId, "test_jssdk_http_task_with_asyncComplete_true", "COMPLETED", { hello: "From manuall api call updating task result" });
+  
+    await new Promise(resolve => setTimeout(resolve, 2000));
+    const workflowStatusAfter = await executor.getWorkflow(executionId, true);
+  
+    expect(workflowStatusAfter.status).toEqual("COMPLETED");
+    expect(workflowStatusAfter.tasks?.[0]?.status).toEqual("COMPLETED");
+  });
 });
 
 describe("Execute with Return Strategy and Consistency", () => {

src/core/generators/HttpTask.ts

@@ -18,6 +18,7 @@ export const generateHTTPTask = (
       method: "GET",
     },
   },
+  asyncComplete: false,
   ...overrides,
   type: TaskType.HTTP,
 });

src/core/sdk/__test__/factory.test.ts

@@ -150,6 +150,7 @@ describe("httpTask", () => {
       method: "GET",
     });
     expect(httpTaskObj).toEqual({
+      asyncComplete: false,
       name: "httpTask",
       taskReferenceName: "httpTask",
       inputParameters: {

src/core/sdk/http.ts

@@ -6,12 +6,14 @@ import {
 
 export const httpTask = (
   taskReferenceName: string,
-  inputParameters: HttpInputParameters
+  inputParameters: HttpInputParameters,
+  asyncComplete: boolean = false
 ): HttpTaskDef => ({
   name: taskReferenceName,
   taskReferenceName,
   inputParameters: {
     http_request: inputParameters,
   },
+  asyncComplete,
   type: TaskType.HTTP,
 });