From 89411f9f529be9d5c6b978bb8e0b4a2b128d43f8 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();
 	{