From 01b380d5f2456648d8b477f132350ff9313382a5 Mon Sep 17 00:00:00 2001
From: Marco Slot <marco.slot@gmail.com>
Date: Thu, 10 Mar 2016 22:10:41 +0100
Subject: [PATCH] Check for interrupts after ending the COPY

---
 src/backend/distributed/commands/multi_copy.c | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/backend/distributed/commands/multi_copy.c b/src/backend/distributed/commands/multi_copy.c
index 9267306ef..2e6c0ee14 100644
--- a/src/backend/distributed/commands/multi_copy.c
+++ b/src/backend/distributed/commands/multi_copy.c
@@ -508,6 +508,8 @@ CitusCopyFrom(CopyStmt *copyStatement, char *completionTag)
 		{
 			PrepareTransactions(connectionList);
 		}
+
+		CHECK_FOR_INTERRUPTS();
 	}
 	PG_CATCH();
 	{