diff --git a/new-user/workflows/new-user-workflow.json b/new-user/workflows/new-user-workflow.json new file mode 100644 index 0000000..77e2062 --- /dev/null +++ b/new-user/workflows/new-user-workflow.json @@ -0,0 +1,262 @@ +[ + { + "createTime": 1703196002469, + "updateTime": 1704216571357, + "name": "user_welcome_journey", + "description": "user_welcome_journey", + "version": 1, + "tasks": [ + { + "name": "fork", + "taskReferenceName": "fork_ref", + "inputParameters": {}, + "type": "FORK_JOIN", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [ + [], + [ + { + "name": "wait_for_lesson", + "taskReferenceName": "wait_for_lesson_1", + "description": "Step 1 - First workflow application", + "inputParameters": { + "docLink": "https://orkes.io/content/getting-started/first-workflow-application" + }, + "type": "WAIT", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + } + ], + [ + { + "name": "wait_for_lesson", + "taskReferenceName": "wait_for_lesson_2", + "description": "Step 2 - Running workflows from code", + "inputParameters": { + "docLink": "https://orkes.io/content/getting-started/running-workflows-from-code" + }, + "type": "WAIT", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + } + ], + [ + { + "name": "wait_for_lesson", + "taskReferenceName": "wait_for_lesson_3", + "description": "Step 3 - Adding custom code worker", + "inputParameters": { + "docLink": "https://orkes.io/content/getting-started/adding-custom-code-worker" + }, + "type": "WAIT", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + } + ], + [ + { + "name": "wait_for_lesson", + "taskReferenceName": "wait_for_lesson_4", + "description": "Step 4 - Running an inline function", + "inputParameters": { + "docLink": "https://orkes.io/content/getting-started/running-an-inline-function" + }, + "type": "WAIT", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + } + ], + [ + { + "name": "wait_for_lesson", + "taskReferenceName": "wait_for_lesson_5", + "description": "Step 5 - Adding wait conditions", + "inputParameters": { + "docLink": "https://orkes.io/content/getting-started/adding-wait-conditions" + }, + "type": "WAIT", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + } + ], + [ + { + "name": "wait_for_lesson", + "taskReferenceName": "wait_for_lesson_6", + "description": "Step 6 - Executing tasks in parallel", + "inputParameters": { + "docLink": "https://orkes.io/content/getting-started/executing-tasks-in-parallel" + }, + "type": "WAIT", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + } + ] + ], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + }, + { + "name": "join", + "taskReferenceName": "join_ref", + "inputParameters": {}, + "type": "JOIN", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + } + ], + "inputParameters": ["userId"], + "outputParameters": {}, + "failureWorkflow": "", + "schemaVersion": 2, + "restartable": true, + "workflowStatusListenerEnabled": false, + "ownerEmail": "gulam.mohiuddeen@orkes.io", + "timeoutPolicy": "ALERT_ONLY", + "timeoutSeconds": 0, + "variables": {}, + "inputTemplate": {} + }, + { + "createTime": 1704437284113, + "updateTime": 1703801235742, + "name": "new_user_Gulam-1704437257709", + "description": "Workflow to run once a new user gets created", + "version": 1, + "tasks": [ + { + "name": "fork", + "taskReferenceName": "fork_ref", + "inputParameters": {}, + "type": "FORK_JOIN", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [ + [ + { + "name": "start_workflow_user_journey", + "taskReferenceName": "start_workflow_user_journey_ref", + "inputParameters": { + "startWorkflow": { + "name": "user_journeyGulam-1704437257709", + "input": {}, + "version": 1, + "correlationId": "user_profile_internal" + } + }, + "type": "START_WORKFLOW", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + } + ] + ], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + }, + { + "name": "join", + "taskReferenceName": "join_ref", + "inputParameters": {}, + "type": "JOIN", + "decisionCases": {}, + "defaultCase": [], + "forkTasks": [], + "startDelay": 0, + "joinOn": [], + "optional": false, + "defaultExclusiveJoinTask": [], + "asyncComplete": false, + "loopOver": [], + "onStateChange": {} + } + ], + "inputParameters": [], + "outputParameters": { + "userJourneyExecutionId": "${start_workflow_user_journey_ref.output.workflowId}" + }, + "failureWorkflow": "", + "schemaVersion": 2, + "restartable": true, + "workflowStatusListenerEnabled": false, + "ownerEmail": "gulam.mohiuddeen+163@orkes.io", + "timeoutPolicy": "ALERT_ONLY", + "timeoutSeconds": 0, + "variables": {}, + "inputTemplate": {} + } +] diff --git a/video-processing/workers/java/.gradle/7.2/dependencies-accessors/dependencies-accessors.lock b/video-processing/workers/java/.gradle/7.2/dependencies-accessors/dependencies-accessors.lock new file mode 100644 index 0000000..a86c921 Binary files /dev/null and b/video-processing/workers/java/.gradle/7.2/dependencies-accessors/dependencies-accessors.lock differ diff --git a/video-processing/workers/java/.gradle/7.2/dependencies-accessors/gc.properties b/video-processing/workers/java/.gradle/7.2/dependencies-accessors/gc.properties new file mode 100644 index 0000000..e69de29 diff --git a/video-processing/workers/java/.gradle/7.2/executionHistory/executionHistory.lock b/video-processing/workers/java/.gradle/7.2/executionHistory/executionHistory.lock new file mode 100644 index 0000000..d6507c2 Binary files /dev/null and b/video-processing/workers/java/.gradle/7.2/executionHistory/executionHistory.lock differ diff --git a/video-processing/workers/java/.gradle/7.2/fileChanges/last-build.bin b/video-processing/workers/java/.gradle/7.2/fileChanges/last-build.bin new file mode 100644 index 0000000..f76dd23 Binary files /dev/null and b/video-processing/workers/java/.gradle/7.2/fileChanges/last-build.bin differ diff --git a/video-processing/workers/java/.gradle/7.2/fileHashes/fileHashes.lock b/video-processing/workers/java/.gradle/7.2/fileHashes/fileHashes.lock new file mode 100644 index 0000000..110f265 Binary files /dev/null and b/video-processing/workers/java/.gradle/7.2/fileHashes/fileHashes.lock differ diff --git a/video-processing/workers/java/.gradle/7.2/gc.properties b/video-processing/workers/java/.gradle/7.2/gc.properties new file mode 100644 index 0000000..e69de29 diff --git a/video-processing/workers/java/.gradle/buildOutputCleanup/buildOutputCleanup.lock b/video-processing/workers/java/.gradle/buildOutputCleanup/buildOutputCleanup.lock new file mode 100644 index 0000000..e03ad09 Binary files /dev/null and b/video-processing/workers/java/.gradle/buildOutputCleanup/buildOutputCleanup.lock differ diff --git a/video-processing/workers/java/.gradle/buildOutputCleanup/cache.properties b/video-processing/workers/java/.gradle/buildOutputCleanup/cache.properties new file mode 100644 index 0000000..20562f9 --- /dev/null +++ b/video-processing/workers/java/.gradle/buildOutputCleanup/cache.properties @@ -0,0 +1,2 @@ +#Thu Jan 11 13:47:35 ART 2024 +gradle.version=7.2 diff --git a/video-processing/workers/java/.gradle/checksums/checksums.lock b/video-processing/workers/java/.gradle/checksums/checksums.lock new file mode 100644 index 0000000..a21865a Binary files /dev/null and b/video-processing/workers/java/.gradle/checksums/checksums.lock differ diff --git a/video-processing/workers/java/.gradle/checksums/md5-checksums.bin b/video-processing/workers/java/.gradle/checksums/md5-checksums.bin new file mode 100644 index 0000000..d4e5056 Binary files /dev/null and b/video-processing/workers/java/.gradle/checksums/md5-checksums.bin differ diff --git a/video-processing/workers/java/.gradle/checksums/sha1-checksums.bin b/video-processing/workers/java/.gradle/checksums/sha1-checksums.bin new file mode 100644 index 0000000..5a3c4ad Binary files /dev/null and b/video-processing/workers/java/.gradle/checksums/sha1-checksums.bin differ diff --git a/video-processing/workers/java/.gradle/vcs-1/gc.properties b/video-processing/workers/java/.gradle/vcs-1/gc.properties new file mode 100644 index 0000000..e69de29 diff --git a/video-processing/workers/java/bin/main/application.properties b/video-processing/workers/java/bin/main/application.properties new file mode 100644 index 0000000..f72f1cb --- /dev/null +++ b/video-processing/workers/java/bin/main/application.properties @@ -0,0 +1,5 @@ +# Update the below with the values you obtain from Orkes Conductor +# TODO: add a documentation link for this +conductor.server.url=https://play.orkes.io/api/ +conductor.security.client.key-id= +conductor.security.client.secret= diff --git a/video-processing/workers/java/bin/main/io/orkes/samples/OrkesWorkersApplication.class b/video-processing/workers/java/bin/main/io/orkes/samples/OrkesWorkersApplication.class new file mode 100644 index 0000000..e98375a Binary files /dev/null and b/video-processing/workers/java/bin/main/io/orkes/samples/OrkesWorkersApplication.class differ diff --git a/video-processing/workers/java/bin/main/io/orkes/samples/utils/S3Utils.class b/video-processing/workers/java/bin/main/io/orkes/samples/utils/S3Utils.class new file mode 100644 index 0000000..4b4f3e9 Binary files /dev/null and b/video-processing/workers/java/bin/main/io/orkes/samples/utils/S3Utils.class differ diff --git a/video-processing/workers/java/bin/main/io/orkes/samples/workers/VIDEO_RECIPE.class b/video-processing/workers/java/bin/main/io/orkes/samples/workers/VIDEO_RECIPE.class new file mode 100644 index 0000000..658ea35 Binary files /dev/null and b/video-processing/workers/java/bin/main/io/orkes/samples/workers/VIDEO_RECIPE.class differ diff --git a/video-processing/workers/java/bin/main/io/orkes/samples/workers/VideoRecipeWorker.class b/video-processing/workers/java/bin/main/io/orkes/samples/workers/VideoRecipeWorker.class new file mode 100644 index 0000000..69f02ea Binary files /dev/null and b/video-processing/workers/java/bin/main/io/orkes/samples/workers/VideoRecipeWorker.class differ diff --git a/video-processing/workers/java/bin/main/io/orkes/samples/workers/VideoRecipesPreForkWorker.class b/video-processing/workers/java/bin/main/io/orkes/samples/workers/VideoRecipesPreForkWorker.class new file mode 100644 index 0000000..32da121 Binary files /dev/null and b/video-processing/workers/java/bin/main/io/orkes/samples/workers/VideoRecipesPreForkWorker.class differ