Describe the problem/error/question
I’m using the Loop Over Items node to process each item one by one.
-
The workflow execution failed, but when I checked my Postgres DB, I saw that all items were updated.
-
In my execution logs, it says
total items executed = 1053. -
However, in my
mql_logstable, the HTTP request triggered 2 times (with a ~9 min gap between hit #1 and hit #2). -
Because of this, users are receiving 2 WhatsApp messages instead of 1 (duplication issue).
It looks like the workflow executes for all items even before the loop finishes.
What is the error message (if any)?
in my exucution logs, it’s saying that total items executed 1053 but the thing is my mql_logs table it is showing that the HTTP request triggerd for 2 times that with difference of 9 min between hit 1 and hit 2, hence my users are receiving 2 messages instead of 1 with repetation
Error/Unexpected Behavior
-
Execution logs: shows 1053 items executed.
-
DB logs (
mql_logs): show duplicate HTTP request triggers (2 hits). -
End result: users get the same WhatsApp message twice.
Please share your workflow
({
"nodes": [
{
"parameters": {
"operation": "executeQuery",
"query": "SELECT * FROM \"MQL\".mql_contacts\nWHERE (\n (count = 0)\n OR \n (count = 1 AND (NOW() AT TIME ZONE 'Asia/Kolkata') - webhook_time > INTERVAL '24 hours')\n OR \n (count = 2 AND (NOW() AT TIME ZONE 'Asia/Kolkata') - webhook_time > INTERVAL '48 hours')\n OR \n (count = 3 AND (NOW() AT TIME ZONE 'Asia/Kolkata') - webhook_time > INTERVAL '72 hours')\n)\n AND\n disposition = 'unqualified'\n ;",
"options": {}
},
"type": "n8n-nodes-base.postgres",
"typeVersion": 2.6,
"position": [
-4112,
10352
],
"id": "24ac3cf2-f1f7-4176-bba0-f093b4094bf9",
"name": "Execute a SQL query",
"alwaysOutputData": true,
"retryOnFail": false,
"credentials": {
"postgres": {
"id": "NLki50A2XVLlGb9l",
"name": "Ampere_WABA"
}
},
"onError": "continueRegularOutput"
},
{
"parameters": {
"rule": {
"interval": [
{
"field": "hours",
"hoursInterval": 3
}
]
}
},
"type": "n8n-nodes-base.scheduleTrigger",
"typeVersion": 1.2,
"position": [
-4416,
10352
],
"id": "78194d86-8b4d-47cf-856d-e48546239fcc",
"name": "Schedule Trigger"
},
{
"parameters": {
"jsCode": "// Define matrix with count mapping\nconst matrix = {\n nexus: {\n 0: \"🛵 Nexus - Electric Scooter of the Year with 165 years of Greaves expertise, 5 national records, 10,000+ km from Kashmir to Kanyakumari, safest Lithium Iron Phosphate battery, 5 yrs/75,000 km warranty & 500+ service points. Thrill + comfort = perfect family ride.\",\n 1: \"⚡️ Nexus is designed for Indian families – dual-frame high ultimate tensile strength steel chassis, best-in-class seat & ground clearance, safest Lithium Iron Phosphate battery chemistry with 2x life vs others. Peace of mind with 5 yrs/75,000 km battery warranty & 500+ service touchpoints. Now that's true long-term comfort.\",\n 2: \"🔋 Nexus has won Electric Scooter of the Year and set 4 national records, including 10,000+ km from Kashmir to Kanyakumari. It's built for thrill, endurance & everyday use – trusted by thousands across India. Choose performance with legacy, choose Nexus.\",\n 3: \"✨ Nexus brings 165 years of trust from Greaves to your family. Lithium Iron Phosphate battery for safety, a premium ride with unbeatable comfort, and 500+ Ampere Care centers to back you always. India's smartest choice for a reliable, electric future – built to last, loved by all.\"\n },\n magnus: {\n 0: \"🛵 Magnus is your perfect city-speed electric scooter – trusted by 165 years of Greaves excellence. With safest Lithium Iron Phosphate battery, 2x life vs others, 5 yrs/75,000 km warranty & 500+ service points. Record-setting 2,300+ km from Bangalore to Delhi. Built for comfort, made for families.\",\n 1: \"⚡️ Magnus is designed for everyday family rides – with best-in-class seat, ground clearance & dual-frame high ultimate tensile strength steel chassis. Lithium Iron Phosphate battery gives 2x life vs NMC batteries. Comes with a 5 yrs/75,000 km battery warranty & 500+ service touchpoints. Easy, safe, and dependable.\",\n 2: \"🔋 Magnus holds a national record – covering 2,300+ km from Bangalore to Delhi. This city-speed champion is built for endurance, comfort & trust. With Greaves' legacy, safest Lithium Iron Phosphate battery, and proven reliability, Magnus is the smart choice for your daily electric journey.\",\n 3: \"✨ Magnus brings Greaves' 165-year legacy to your family rides. Safe Lithium Iron Phosphate battery, low running cost, long warranty, and 500+ Ampere Care centers ensure peace of mind. Magnus is built to handle city life with ease, comfort, and unmatched reliability.\"\n },\n reo: {\n 0: \"🛵 Reo is the perfect no license, no registration electric scooter – designed for everyday ease with 165 years of Greaves trust. Comes with safest LFP battery (2x life vs NMC), built for comfort, and ideal for short city rides. Easy to ride, easy to own – Reo makes life simple.\",\n 1: \"⚡️ Reo is built for stress-free city rides – no license, no registration needed. Just charge and go! With safest LFP battery chemistry and 2x battery life vs others, Reo is your go-to ride for smooth, safe, everyday movement. Ride smart with peace of mind.\",\n 2: \"🔋 Reo is ideal for beginners and families – super easy to ride, no paperwork, no learning curve. With Greaves' trusted legacy and safest Lithium Iron Phosphate battery tech, it's the perfect blend of comfort, safety, and convenience. Reo makes the switch to electric effortless.\",\n 3: \"✨ Reo gives unmatched daily value – no license hassles, zero registration cost, and super low running expense. With 2x battery life, strong build, and 165 years of trusted Greaves engineering, Reo is built to save you time and money – every single day.\"\n },\n general: {\n 0: \"🛵 Ampere electric scooters are built for every Indian family – from city rides to high-performance journeys. Backed by 165 years of Greaves trust, our scooters use safest LFP batteries (2x life), 500+ service points & 5 yrs/75,000 km battery warranty. Find your perfect fit!\",\n 1: \"⚡️ Looking for a safe, easy-to-use electric scooter? Ampere scooters offer no license models, comfort-first designs, and LFP battery chemistry that lasts 2x longer than others. Backed by Greaves' 165-year legacy. The switch to electric just got easier – explore now.\",\n 2: \"🔋 Ampere scooters are national record-setters – with 10,000+ km rides and award-winning performance. Whether it's Nexus, Magnus or Reo, every model is designed for real Indian roads and families. Powered by legacy, built for today. Let's find your ideal ride.\",\n 3: \"✨ Choosing Ampere means peace of mind – with 500+ service touchpoints, 5 yrs/75,000 km battery warranty, and the safest LFP tech. From beginners to power riders, there's an Ampere for everyone. Let us help you pick the right one. Ready to explore?\"\n }\n};\n\n// Get inputs from previous node\nconst model = $input.first().json.model// \"nexus\" / \"reo\" / \"magnus\" / \"general\"\nconst count = $input.first().json.count // 0 / 1 / 2 / 3\n\n// const model = \"general\"; \n// const count = 0; \n\n// Fetch matching content\nconst output = matrix[model]?.[count] || \"🛵 Ampere electric scooters are built for every Indian family – from city rides to high-performance journeys. Backed by 165 years of Greaves trust, our scooters use safest LFP batteries (2x life), 500+ service points & 5 yrs/75,000 km battery warranty. Find your perfect fit!\";\n\n// Return as output\nreturn [{ json: { model, count, output } }];"
},
"type": "n8n-nodes-base.code",
"typeVersion": 2,
"position": [
-2944,
10368
],
"id": "3301f70b-8818-4506-b0fc-8fedb46673e0",
"name": "Code1",
"onError": "continueRegularOutput"
},
{
"parameters": {
"options": {}
},
"type": "n8n-nodes-base.splitInBatches",
"typeVersion": 3,
"position": [
-3632,
10352
],
"id": "deeb3411-7ea1-414c-b70c-c34055306021",
"name": "Loop Over Items4"
},
{
"parameters": {
"method": "POST",
"url": "https://server.gallabox.com/devapi/messages/whatsapp",
"authentication": "genericCredentialType",
"genericAuthType": "httpCustomAuth",
"sendHeaders": true,
"specifyHeaders": "json",
"jsonHeaders": "{\n \"apiKey\": \"( have done correctly )\",\n \"apiSecret\": \" have done correctly )\"\n}",
"sendBody": true,
"specifyBody": "json",
"jsonBody": "=\n{\n \"channelId\": \"680b64f96a0f98eaa05eaf40\",\n \"channelType\": \"whatsapp\",\n \"recipient\": {\n \"name\": \"{{ $('Execute a SQL query').item.json.name }}\",\n \"phone\": \"91{{ $('Execute a SQL query').item.json.phone }}\"\n },\n \"whatsapp\": {\n \"type\": \"template\",\n \"template\": {\n \"templateName\": \"waba_qual_21july25\",\n \"bodyValues\": {\n \"Name\": \"{{ $('Execute a SQL query').item.json.name }}\",\n \"Details\": \"{{ $json.output }}\"\n },\n \"buttonValues\": [\n {\n \"index\": 0,\n \"sub_type\": \"quick_reply\",\n \"parameters\": {\n \"type\": \"payload\",\n \"payload\": \"Show Brochure\"\n }\n },\n {\n \"index\": 1,\n \"sub_type\": \"quick_reply\",\n \"parameters\": {\n \"type\": \"payload\",\n \"payload\": \"Get Showroom Location\"\n }\n },\n {\n \"index\": 2,\n \"sub_type\": \"quick_reply\",\n \"parameters\": {\n \"type\": \"payload\",\n \"payload\": \"Not Interested\"\n }\n }\n ]\n }\n }\n}",
"options": {
"response": {
"response": {
"fullResponse": true
}
}
}
},
"id": "8b059291-8a13-4bb6-8981-fceb292a9327",
"name": "new_lead_4",
"type": "n8n-nodes-base.httpRequest",
"typeVersion": 4.1,
"position": [
-2368,
10368
],
"credentials": {
"httpCustomAuth": {
"id": "Vig3s71byLLrou33",
"name": "Gallabox API Ampere"
}
},
"onError": "continueRegularOutput"
},
{
"parameters": {
"operation": "update",
"schema": {
"__rl": true,
"value": "MQL",
"mode": "list",
"cachedResultName": "MQL"
},
"table": {
"__rl": true,
"value": "mql_contacts",
"mode": "list",
"cachedResultName": "mql_contacts"
},
"columns": {
"mappingMode": "defineBelow",
"value": {
"phone": "={{ $('Execute a SQL query').item.json.phone }}",
"last_message_sent": "={{ $('new_lead_4').item.json.headers.date }}",
"count": "={{ $('Execute a SQL query').item.json.count + 1 }}"
},
"matchingColumns": [
"phone"
],
"schema": [
{
"id": "id",
"displayName": "id",
"required": false,
"defaultMatch": true,
"display": true,
"type": "string",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "created_at",
"displayName": "created_at",
"required": false,
"defaultMatch": false,
"display": true,
"type": "dateTime",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "updated_at",
"displayName": "updated_at",
"required": false,
"defaultMatch": false,
"display": true,
"type": "dateTime",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "name",
"displayName": "name",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "phone",
"displayName": "phone",
"required": true,
"defaultMatch": false,
"display": true,
"type": "number",
"canBeUsedToMatch": true,
"removed": false
},
{
"id": "last_message_sent",
"displayName": "last_message_sent",
"required": false,
"defaultMatch": false,
"display": true,
"type": "dateTime",
"canBeUsedToMatch": true
},
{
"id": "disposition",
"displayName": "disposition",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "count",
"displayName": "count",
"required": false,
"defaultMatch": false,
"display": true,
"type": "number",
"canBeUsedToMatch": true,
"removed": false
},
{
"id": "interval",
"displayName": "interval",
"required": false,
"defaultMatch": false,
"display": true,
"type": "number",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "remarks",
"displayName": "remarks",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "model",
"displayName": "model",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "pincode",
"displayName": "pincode",
"required": false,
"defaultMatch": false,
"display": true,
"type": "number",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "ABOS API status",
"displayName": "ABOS API status",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "webhook_time",
"displayName": "webhook_time",
"required": false,
"defaultMatch": false,
"display": true,
"type": "dateTime",
"canBeUsedToMatch": true,
"removed": true
}
],
"attemptToConvertTypes": false,
"convertFieldsToString": false
},
"options": {}
},
"type": "n8n-nodes-base.postgres",
"typeVersion": 2.6,
"position": [
-1776,
10368
],
"id": "70b6e8c8-0279-4f11-881e-84b240170456",
"name": "Update rows in a table4",
"retryOnFail": false,
"credentials": {
"postgres": {
"id": "NLki50A2XVLlGb9l",
"name": "Ampere_WABA"
}
},
"onError": "continueRegularOutput"
},
{
"parameters": {
"content": "The timing for messages is set here",
"height": 80,
"width": 176
},
"type": "n8n-nodes-base.stickyNote",
"typeVersion": 1,
"position": [
-4160,
10240
],
"id": "cf465885-d1fb-49ed-9564-c7c95654b26a",
"name": "Sticky Note6"
},
{
"parameters": {
"amount": 0.5
},
"type": "n8n-nodes-base.wait",
"typeVersion": 1.1,
"position": [
-3232,
10368
],
"id": "69f1ef95-599e-45f7-bf1f-ec1f42c5b851",
"name": "Wait1",
"webhookId": "f22ab9f3-98ab-45d4-bdb7-ae06a8b4ea98"
},
{
"parameters": {
"schema": {
"__rl": true,
"value": "MQL",
"mode": "list",
"cachedResultName": "MQL"
},
"table": {
"__rl": true,
"value": "mql_logs",
"mode": "list",
"cachedResultName": "mql_logs"
},
"columns": {
"mappingMode": "defineBelow",
"value": {
"phone": "={{ $('Execute a SQL query').item.json.phone }}",
"mes_count": "={{ $('Execute a SQL query').item.json.count }}",
"message_id": "={{ $json.body.id }}",
"name": "={{ $('Execute a SQL query').item.json.name }}",
"disposition": "={{ $('Execute a SQL query').item.json.disposition }}",
"gb_status_message": "={{ $json.body.status }}",
"gb_status_code": "={{ $json.statusCode }}",
"last_sent": "={{ $('Execute a SQL query').item.json.last_message_sent }}",
"remarks": "Workflow 1"
},
"matchingColumns": [
"id"
],
"schema": [
{
"id": "id",
"displayName": "id",
"required": false,
"defaultMatch": true,
"display": true,
"type": "string",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "created_at",
"displayName": "created_at",
"required": false,
"defaultMatch": false,
"display": true,
"type": "dateTime",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "updated_at",
"displayName": "updated_at",
"required": false,
"defaultMatch": false,
"display": true,
"type": "dateTime",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "message_id",
"displayName": "message_id",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true
},
{
"id": "name",
"displayName": "name",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true
},
{
"id": "phone",
"displayName": "phone",
"required": true,
"defaultMatch": false,
"display": true,
"type": "number",
"canBeUsedToMatch": true
},
{
"id": "disposition",
"displayName": "disposition",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true
},
{
"id": "mes_count",
"displayName": "mes_count",
"required": false,
"defaultMatch": false,
"display": true,
"type": "number",
"canBeUsedToMatch": true
},
{
"id": "last_sent",
"displayName": "last_sent",
"required": false,
"defaultMatch": false,
"display": true,
"type": "dateTime",
"canBeUsedToMatch": true
},
{
"id": "gb_status_code",
"displayName": "gb_status_code",
"required": false,
"defaultMatch": false,
"display": true,
"type": "number",
"canBeUsedToMatch": true
},
{
"id": "gb_status_message",
"displayName": "gb_status_message",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true
},
{
"id": "message_status_meta",
"displayName": "message_status_meta",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "cta",
"displayName": "cta",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "remarks",
"displayName": "remarks",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true
},
{
"id": "dispo_updated",
"displayName": "dispo_updated",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true,
"removed": true
}
],
"attemptToConvertTypes": false,
"convertFieldsToString": false
},
"options": {}
},
"type": "n8n-nodes-base.postgres",
"typeVersion": 2.6,
"position": [
-2048,
10368
],
"id": "23c238c1-2150-4dd8-8d39-88dcddb76f6e",
"name": "Insert rows in a table4",
"retryOnFail": false,
"executeOnce": false,
"credentials": {
"postgres": {
"id": "NLki50A2XVLlGb9l",
"name": "Ampere_WABA"
}
},
"onError": "continueRegularOutput"
},
{
"parameters": {
"schema": {
"__rl": true,
"value": "MQL",
"mode": "list",
"cachedResultName": "MQL"
},
"table": {
"__rl": true,
"value": "pre_logs",
"mode": "list",
"cachedResultName": "pre_logs"
},
"columns": {
"mappingMode": "defineBelow",
"value": {
"name": "={{ $('Execute a SQL query').item.json.name }}",
"phone": "={{ $('Execute a SQL query').item.json.phone }}",
"details": "={{ $json.output }}",
"log_time": "={{ $now }}"
},
"matchingColumns": [
"id"
],
"schema": [
{
"id": "id",
"displayName": "id",
"required": false,
"defaultMatch": true,
"display": true,
"type": "number",
"canBeUsedToMatch": true,
"removed": true
},
{
"id": "log_time",
"displayName": "log_time",
"required": false,
"defaultMatch": false,
"display": true,
"type": "dateTime",
"canBeUsedToMatch": true
},
{
"id": "name",
"displayName": "name",
"required": true,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true
},
{
"id": "phone",
"displayName": "phone",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true
},
{
"id": "details",
"displayName": "details",
"required": false,
"defaultMatch": false,
"display": true,
"type": "string",
"canBeUsedToMatch": true
}
],
"attemptToConvertTypes": false,
"convertFieldsToString": false
},
"options": {}
},
"type": "n8n-nodes-base.postgres",
"typeVersion": 2.6,
"position": [
-2624,
10224
],
"id": "6a08e6b0-1912-4511-96f2-124232e94926",
"name": "Insert rows in a table",
"credentials": {
"postgres": {
"id": "NLki50A2XVLlGb9l",
"name": "Ampere_WABA"
}
},
"onError": "continueRegularOutput"
}
],
"connections": {
"Execute a SQL query": {
"main": [
[
{
"node": "Loop Over Items4",
"type": "main",
"index": 0
}
]
]
},
"Schedule Trigger": {
"main": [
[
{
"node": "Execute a SQL query",
"type": "main",
"index": 0
}
]
]
},
"Code1": {
"main": [
[
{
"node": "new_lead_4",
"type": "main",
"index": 0
},
{
"node": "Insert rows in a table",
"type": "main",
"index": 0
}
]
]
},
"Loop Over Items4": {
"main": [
[],
[
{
"node": "Wait1",
"type": "main",
"index": 0
}
]
]
},
"new_lead_4": {
"main": [
[
{
"node": "Insert rows in a table4",
"type": "main",
"index": 0
}
]
]
},
"Update rows in a table4": {
"main": [
[
{
"node": "Loop Over Items4",
"type": "main",
"index": 0
}
]
]
},
"Wait1": {
"main": [
[
{
"node": "Code1",
"type": "main",
"index": 0
}
]
]
},
"Insert rows in a table4": {
"main": [
[
{
"node": "Update rows in a table4",
"type": "main",
"index": 0
}
]
]
},
"Insert rows in a table": {
"main": [
[
{
"node": "new_lead_4",
"type": "main",
"index": 0
}
]
]
}
},
"pinData": {},
"meta": {
"templateCredsSetupCompleted": true,
"instanceId": "c36fcd5112c35c8aaef5ffc531586f986768ae38ab8989c1500c27bfa958b61a"
}
})
Share the output returned by the last node
Information on your n8n setup
-
n8n version: Version 1.107.4 ( self hosted )
-
Database (default: SQLite): Postgres
-
n8n EXECUTIONS_PROCESS setting (default: own, main): own
-
Running n8n via (Docker, npm, n8n cloud, desktop app): Selfhosted
-
Operating system: Macos
