The workflow JSON
Copy or download the full n8n JSON below. Paste it into a new n8n workflow, add your credentials, activate. Full import guide →
{
"name": "CWF-440 Media Package Finalizer Canonical",
"description": "Assembles all media assets into final production package.",
"nodes": [
{
"parameters": {},
"id": "trigger",
"name": "Trigger",
"type": "n8n-nodes-base.executeWorkflowTrigger",
"typeVersion": 1,
"position": [
200,
300
]
},
{
"parameters": {
"jsCode": "const mediaPackage = {instance_id: 'MEDIA-' + Date.now(), artifact_family: 'media_production_packet', schema_version: '1.0.0', producer_workflow: 'CWF-440', dossier_ref: $json.dossier_id, created_at: new Date().toISOString(), status: 'CREATED', payload: {media_package_assembled: true, constituent_packets: ['thumbnail_concept_packet', 'visual_asset_plan_packet', 'audio_optimized_script_packet'], asset_integrity_verified: true, all_assets_present: true, quality_gates_passed: true, ready_for_publishing: true}};\nreturn [{ json: { ...$json, cwf440_result: { status: 'COMPLETED', media_production_packet: mediaPackage } } }];"
},
"id": "builder",
"name": "Builder",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
420,
300
]
},
{
"parameters": {
"jsCode": "try {\n const SkillLoader = require('../../../engine/skill_loader/skill_loader.js');\n const loader = new SkillLoader();\n\n if (!loader.skills_registry || Object.keys(loader.skills_registry).length === 0) {\n const initResult = await loader.initialize();\n if (initResult.status !== 'initialized') {\n throw new Error('Failed to initialize SkillLoader');\n }\n }\n\n const workflowId = 'CWF-440';\n const defaultSkillMap = {\"CWF-310\":\"M-001\",\"CWF-320\":\"M-001\",\"CWF-330\":\"M-001\",\"CWF-340\":\"M-001\",\"CWF-410\":\"M-001\",\"CWF-420\":\"M-001\",\"CWF-430\":\"M-001\",\"CWF-440\":\"M-001\",\"CWF-510\":\"M-001\",\"CWF-520\":\"M-001\",\"CWF-530\":\"M-001\"};\n const skillId = $json.skill_id || defaultSkillMap[workflowId] || 'M-001';\n const dossierId = $json.dossier_context?.dossier_id || $json.dossier_id || 'DOSSIER-UNSPECIFIED';\n\n const contextPacket = {\n dossier_id: dossierId,\n workflow_id: workflowId,\n ...(typeof $json.user_context === 'object' ? $json.user_context : {}),\n ...(typeof $json.route_context === 'object' ? $json.route_context : {})\n };\n\n const dossierState = typeof $json.dossier === 'object' ? $json.dossier : {};\n const result = await loader.executeSkill(skillId, contextPacket, dossierState);\n\n return [{\n json: {\n ...$json,\n phase8_runtime_probe: {\n workflow_id: workflowId,\n skill_id: skillId,\n status: result.status,\n had_error: result.status !== 'SUCCESS',\n error_message: result.status === 'SUCCESS' ? '' : String(result.error || ''),\n timestamp: new Date().toISOString()\n },\n runtime_packet: result.status === 'SUCCESS' ? (result.output || null) : null,\n skill_execution_result: result.status === 'SUCCESS' ? result : null,\n runtime: {\n had_error: result.status !== 'SUCCESS',\n error_message: result.status === 'SUCCESS' ? '' : String(result.error || '')\n }\n }\n }];\n} catch (error) {\n const message = String(error && error.message ? error.message : error);\n return [{\n json: {\n ...$json,\n phase8_runtime_probe: {\n workflow_id: 'CWF-440',\n skill_id: null,\n status: 'ERROR',\n had_error: true,\n error_message: message,\n timestamp: new Date().toISOString()\n },\n runtime_packet: null,\n skill_execution_result: null,\n runtime: { had_error: true, error_message: message }\n }\n }];\n}"
},
"id": "cwf_440_skill_runtime_probe_node",
"name": "Skill Runtime Probe Node",
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
420,
300
]
}
],
"connections": {
"Trigger": {
"main": [
[
{
"node": "Skill Runtime Probe Node",
"type": "main",
"index": 0
}
]
]
},
"Builder": {
"main": [
[]
]
},
"Skill Runtime Probe Node": {
"main": [
[
{
"node": "Builder",
"type": "main",
"index": 0
}
]
]
}
},
"meta": {
"workflow_id": "CWF-440",
"phase": "phase4",
"vein": "media_vein",
"purpose": "Final media QA (deferred).",
"implementation_depth": "phase_deferred_stub",
"owner_director": "narada",
"next_workflow": "WF-500",
"canonical_file": "n8n/workflows/CWF-440.json",
"wf900_error_route": "WF-900"
},
"active": true
}
For the full experience including quality scoring and batch install features for each workflow upgrade to Pro
About this workflow
CWF-440 Media Package Finalizer Canonical. Uses executeWorkflowTrigger. Event-driven trigger; 3 nodes.
Source: https://github.com/justkalpane/Shadow-Creator-OS-Phase_01/blob/0447c2f91c0b7669a61f768fac60fa911acf2cc5/n8n/workflows/CWF-440.json — original creator credit. Request a take-down →
Related workflows
Workflows that share integrations, category, or trigger type with this one. All free to copy and import.
Agendamiento. Uses n8n-nodes-evolution-api, redis, dataTable, executeWorkflowTrigger. Event-driven trigger; 60 nodes.
Prevent concurrent workflow runs using Redis. Uses executeWorkflowTrigger, manualTrigger, stickyNote, executeWorkflow. Event-driven trigger; 43 nodes.
This workflow sets a small "lock" value in Redis so that only one copy of a long job can run at the same time. If another trigger fires while the job is still busy, the workflow sees the lock, stops e
Reputation Engine — Site Refresh. Uses httpRequest, executeWorkflowTrigger. Event-driven trigger; 35 nodes.
Using n8n a lot?