diff --git a/luigi/contrib/rdbms.py b/luigi/contrib/rdbms.py
index a9e0429a9b..ca24ae8ff1 100644
--- a/luigi/contrib/rdbms.py
+++ b/luigi/contrib/rdbms.py
@@ -249,7 +249,7 @@ def init_copy(self, connection):
             raise Exception("The clear_table attribute has been removed. Override init_copy instead!")
 
         if self.enable_metadata_columns:
-            self._add_metadata_columns(connection.cursor())
+            self._add_metadata_columns(connection)
 
     def post_copy(self, connection):
         """