diff --git a/vistrails/db/services/opm.py b/vistrails/db/services/opm.py
index ae6a0516e..837964b30 100644
--- a/vistrails/db/services/opm.py
+++ b/vistrails/db/services/opm.py
@@ -271,6 +271,10 @@ def process_map(module, found_input_ports, found_output_ports):
             # need to have process that extracts artifacts for each iteration
             input_list_artifact = found_input_ports['InputList']
             result_artifact = found_output_ports.get('Result', None)
+            # if InputPort or OutputPort is a Connection we cannot do anything
+            if (found_input_ports['InputPort'].vtType == DBConnection.vtType or
+                found_input_ports['OutputPort'].vtType == DBConnection.vtType):
+                return
             input_port_list = \
                 literal_eval(found_input_ports['InputPort'].db_parameters[0].db_val)
             output_port = \