Job Manager Plugin

8min
This plugin will interpret the current event and, if required, it will either create a new job or update an existing one.
Use case
Create a Job for a work-order created event.
Create a Job for the job completed event where reasonCode != R-0065 (re-attempt).
Input
tenantId
pickupLocation
pickupContact
deliverLocation
deliverContact
jobWorkflowId
jobTypeId
jobTypeName
objectives
customData
orderId
workOrderId
callback
Output
CreateJobCommand
Logic
If pickupLocation != deliverLocation -> CreateJobCommand returned
Current Configuration
Rule
Create a new job.
Create a New Job
{
	"name": "Create a new job",
	"event": "WorkOrderCreatedEvent",
	"pluginWorkflowId": "plugin-workflow:da9eb6dc-ee81-51e5-aed1-100244711ba6",
	"serviceName": "orchestrator"
}
{
	"name": "Create a new job",
	"event": "WorkOrderCreatedEvent",
	"pluginWorkflowId": "plugin-workflow:da9eb6dc-ee81-51e5-aed1-100244711ba6",
	"serviceName": "orchestrator"
}
﻿
  Create a job after the previous one fails.
Create a Job after the Previous One fails
{
    "name": "Complete Job Failure",
    "event": "CompleteJobEvent",
    "pluginWorkflowId": "plugin-workflow:da9eb6dc-ee81-51e5-aed1-100244711ba6",
    "serviceName": "orchestrator",
    "logic": {
        "!=": [
            "$.reason",
            "R-0065"
        ]
    }
}
{
    "name": "Complete Job Failure",
    "event": "CompleteJobEvent",
    "pluginWorkflowId": "plugin-workflow:da9eb6dc-ee81-51e5-aed1-100244711ba6",
    "serviceName": "orchestrator",
    "logic": {
        "!=": [
            "$.reason",
            "R-0065"
        ]
    }
}
﻿
Plugin Workflow
Create a new job
JSON
{
	"name": "CreateJobWf",
	"description": "workflow for order creation",
	"tag": [{
		"name": "workOrderCreated",
		"value": "workflow"
	}],
	"pre": {
		"plugins": [
			"fetchData"
		]
	},
	"main": {
		"plugins": [
			"workflowManagerPluginV4"
			"jobManagerPluginV10"
		]
	}
}
{
	"name": "CreateJobWf",
	"description": "workflow for order creation",
	"tag": [{
		"name": "workOrderCreated",
		"value": "workflow"
	}],
	"pre": {
		"plugins": [
			"fetchData"
		]
	},
	"main": {
		"plugins": [
			"workflowManagerPluginV4"
			"jobManagerPluginV10"
		]
	}
}
﻿
Create a job after the previous one fails.
Create Another Job
{
    "name": "JobFailureWorkflow",
    "description": "workflow for job failure",
    "pre": {
        "plugins": [
            "fetchData"
        ]
    },
    "main": {
        "plugins": [
            "jobManagerPluginV10"
        ]
    }
}
{
    "name": "JobFailureWorkflow",
    "description": "workflow for job failure",
    "pre": {
        "plugins": [
            "fetchData"
        ]
    },
    "main": {
        "plugins": [
            "jobManagerPluginV10"
        ]
    }
}
﻿
Plugin
Plugin
{
    "name": "jobManagerPlugin",
    "httpUrl": "https://delhivery.preprod.fxtrt.io/core/api/v1/jobManager/",
    "httpMethod": "POST",
    "httpHeaders": {
        "plugin": "jobManager"
    },
    "httpRequestBodyTemplate": [
        {
            "outputJsonPath": {
                "tenantId": "$.tenantId",
                "jobWorkflowId": "$.workflowManagerPluginV4.jobWorkflowId",
                "jobTypeId": "$.workflowManagerPluginV4.jobTypeId",
                "jobTypeName": "$.workflowManagerPluginV4.jobTypeName",
                "objectives": "$.workflowManagerPluginV4.objectives",
                "customData": "$.workflowManagerPluginV4.customData",
                "deliverLocation": "$.dropDetails.location",
                "deliverContact": "$.dropDetails.contact",
                "orderId": "$.orderId",
                "workOrderId": "$.workOrders[0].id"
            }
        },
        {
            "entity": "container",
            "input": {
                "tenant_id": "$.tenantId",
                "id": "$.workOrders[0].containers[0]"
            },
            "outputJsonPath": {
                "trackingDetails": "$.trackingDetails"
            }
        }
    ],
    "dlqOnFailure": true,
    "requestTimeout": 5,
    "callbackTimeout": 5,
    "responseType": "ASYNC",
    "secretKey": "SECRET_KEY",
    "protocol": "HTTP"
}
{
    "name": "jobManagerPlugin",
    "httpUrl": "https://delhivery.preprod.fxtrt.io/core/api/v1/jobManager/",
    "httpMethod": "POST",
    "httpHeaders": {
        "plugin": "jobManager"
    },
    "httpRequestBodyTemplate": [
        {
            "outputJsonPath": {
                "tenantId": "$.tenantId",
                "jobWorkflowId": "$.workflowManagerPluginV4.jobWorkflowId",
                "jobTypeId": "$.workflowManagerPluginV4.jobTypeId",
                "jobTypeName": "$.workflowManagerPluginV4.jobTypeName",
                "objectives": "$.workflowManagerPluginV4.objectives",
                "customData": "$.workflowManagerPluginV4.customData",
                "deliverLocation": "$.dropDetails.location",
                "deliverContact": "$.dropDetails.contact",
                "orderId": "$.orderId",
                "workOrderId": "$.workOrders[0].id"
            }
        },
        {
            "entity": "container",
            "input": {
                "tenant_id": "$.tenantId",
                "id": "$.workOrders[0].containers[0]"
            },
            "outputJsonPath": {
                "trackingDetails": "$.trackingDetails"
            }
        }
    ],
    "dlqOnFailure": true,
    "requestTimeout": 5,
    "callbackTimeout": 5,
    "responseType": "ASYNC",
    "secretKey": "SECRET_KEY",
    "protocol": "HTTP"
}
﻿
Try Job Manager Plugin API﻿
Updated 08 Aug 2023
Did this page help you?
How to Get the Execution Rule
Container Manager Plugin