The requested operation is invalid on a closed state
14664
11
03-25-2015 01:38 PM
by
by
by
by
by
by
Following for the ArcPy Pro rewrite 
by
Coming soon...we have to migrate a lot of code to be compatible with 3.x 
by
Here is your 3.x compatible version 
import os
import arcpy
import warnings
class WSMixin(object):
@staticmethod
def find_ws(path, ws_type='', return_type=False):
"""finds a valid workspace path for an arcpy.da.Editor() Session
Required:
path -- path to features or workspace
Optional:
ws_type -- option to find specific workspace type (FileSystem|LocalDatabase|RemoteDatabase)
return_type -- option to return workspace type as well. If this option is selected, a tuple
of the full workspace path and type are returned
"""
def find_existing(path):
if arcpy.Exists(path):
return arcpy.Describe(path).catalogPath
else:
if not arcpy.Exists(path):
return find_existing(os.path.dirname(path))
# try original path first
if hasattr(arcpy, 'mapping'):
if isinstance(path, (arcpy.mapping.Layer, arcpy.mapping.TableView)):
path = path.dataSource
else:
if isinstance(path, (arcpy._mp.Layer, arcpy._mp.Table)):
path = path.dataSource
if os.sep not in str(path):
if hasattr(path, 'dataSource'):
path = path.dataSource
else:
path = arcpy.Describe(path).catalogPath
path = find_existing(path)
# first make sure it's not an "in_memory" workspace
if (path or '').startswith('in_memory'):
return ('in_memory', 'LocalDatabase') if return_type else 'in_memory'
desc = arcpy.Describe(path)
if hasattr(desc, 'workspaceType'):
if ws_type == desc.workspaceType:
if return_type:
return (path, desc.workspaceType)
else:
return path
else:
if return_type:
return (path, desc.workspaceType)
else:
return path
# search until finding a valid workspace
path = str(path)
split = list(filter(None, str(path).split(os.sep)))
if path.startswith('\\\\'):
split[0] = r'\\{0}'.format(split[0])
# find valid workspace
for i in range(1, len(split)):
sub_dir = os.sep.join(split[:-i])
desc = arcpy.Describe(sub_dir)
if hasattr(desc, 'workspaceType'):
if ws_type == desc.workspaceType:
if return_type:
return (sub_dir, desc.workspaceType)
else:
return sub_dir
else:
if return_type:
return (sub_dir, desc.workspaceType)
else:
return sub_dir
class InsertCursor(WSMixin):
"""wrapper clas for arcpy.da.InsertCursor, to automatically
implement editing (required for versioned data, and data with
geometric networks, topologies, network datasets, and relationship
classes"""
def __init__(self, *args, **kwargs):
"""initiate wrapper class for update cursor. Supported args:
in_table, field_names
"""
self.args = args
self.kwargs = kwargs
self.edit = None
self.alreadyInEditSession = False
def __enter__(self):
ws = None
if self.args:
ws = self.find_ws(self.args[0])
elif 'in_table' in self.kwargs:
ws = self.find_ws(self.kwargs['in_table'])
try:
self.edit = arcpy.da.Editor(ws)
self.edit.startEditing()
self.edit.startOperation()
self.cursor = arcpy.da.InsertCursor(*self.args, **self.kwargs)
return self.cursor
except Exception as e:
# explicit check for active edit session, do not attempt starting new session
if isinstance(e, RuntimeError) and e.message == 'start edit session':
self.cursor = arcpy.da.InsertCursor(*self.args, **self.kwargs)
self.alreadyInEditSession = True
return self.cursor
else:
raise e
def __exit__(self, type, value, traceback):
if not self.alreadyInEditSession:
try:
self.edit.stopOperation()
self.edit.stopEditing(True)
except Exception as e:
warnings.warn("Exception On Insert Cursor! Records May Not Have Inserted: {}".format(e))
self.edit = None
try:
del self.cursor
except:
pass
class UpdateCursor(WSMixin):
"""wrapper clas for arcpy.da.UpdateCursor, to automatically
implement editing (required for versioned data, and data with
geometric networks, topologies, network datasets, and relationship
classes"""
def __init__(self, *args, **kwargs):
"""initiate wrapper class for update cursor. Supported args:
in_table, field_names, where_clause=None, spatial_reference=None,
explode_to_points=False, sql_clause=(None, None)
"""
self.args = args
self.kwargs = kwargs
self.edit = None
self.alreadyInEditSession = False
def __enter__(self):
ws = None
if self.args:
ws = self.find_ws(self.args[0])
elif 'in_table' in self.kwargs:
ws = self.find_ws(self.kwargs['in_table'])
try:
self.edit = arcpy.da.Editor(ws)
self.edit.startEditing()
self.edit.startOperation()
self.cursor = arcpy.da.UpdateCursor(*self.args, **self.kwargs)
return self.cursor
except Exception as e:
# explicit check for active edit session, do not attempt starting new session
if isinstance(e, RuntimeError) and e.message == 'start edit session':
self.cursor = arcpy.da.UpdateCursor(*self.args, **self.kwargs)
self.alreadyInEditSession = True
return self.cursor
else:
raise e
def __exit__(self, type, value, traceback):
if not self.alreadyInEditSession:
try:
self.edit.stopOperation()
self.edit.stopEditing(True)
except Exception as e:
warnings.warn("Exception On Update Cursor! Records May Not Have Updated: {}".format(e))
self.edit = None
try:
del self.cursor
except:
pass
by
by