Function __new__ has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

    def __new__(cls, name, bases, defined_attrs):
        datastreams = {}
        local_datastreams = {}
        use_attrs = defined_attrs.copy()
        reverse_rels = {}

• Read up
  Read up

Function addDatastream has 14 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def addDatastream(self, pid, dsID, dsLabel=None, mimeType=None, logMessage=None,

Function modifyDatastream has 14 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def modifyDatastream(self, pid, dsID, dsLabel=None, mimeType=None, logMessage=None, dsLocation=None,

Function _save_existing has a Cognitive Complexity of 14 (exceeds 5 allowed). Consider refactoring.

Open

    def _save_existing(self, logMessage):
        # save an object that has already been ingested into fedora

        # - list of datastreams that should be saved
        to_save = [ds for ds, dsobj in six.iteritems(self.dscache) if dsobj.isModified()]

• Read up
  Read up

Function _build_foxml_datastream has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def _build_foxml_datastream(self, E, dsid, dsobj):

        # if we can't construct a content node then bail before constructing
        # any other nodes
        content_node = None

• Read up
  Read up

Function modify_relationship has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def modify_relationship(self, rel_uri, old_object, new_object):
        """
        Modify a relationship from RELS-EXT for this object.  As the Fedora API-M does not contain
        a native "modifyRelationship", this method purges an existing one, then adds a new one,
        pivoting on the predicate.

• Read up
  Read up

Function sync_object has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

def sync_object(src_obj, dest_repo, export_context='migrate',
                overwrite=False, show_progress=False,
                requires_auth=False, omit_checksums=False,
                verify=False):
    '''Copy an object from one repository to another using the Fedora

• Read up
  Read up

Function upload has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def upload(self, data, callback=None, content_type=None,
               size=None):
        '''
        Upload a multi-part file for content to ingest.  Returns a
        temporary upload id that can be used as a datstream location.

• Read up
  Read up

Function binarycontent_sections has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

def binarycontent_sections(chunk):
    '''Split a chunk of data into sections by start and end binary
    content tags.'''
    # using string split because it is significantly faster than regex.

• Read up
  Read up

Function getDatastreamObject has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def getDatastreamObject(self, dsid, dsobj_type=None, as_of_date=None):
        '''Get any datastream on this object as a :class:`DatastreamObject`
        **or** add a new datastream.  If the datastream id corresponds
        to a predefined datastream, the configured object will be returned
        and the datastream object will be returned.  If type is not

• Read up
  Read up

Function __init__ has 11 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def __init__(self, obj, id, label, mimetype=None, versionable=False,

Function raw_datastream_old has 9 arguments (exceeds 4 allowed). Consider refactoring.

Open

def raw_datastream_old(request, pid, dsid, type=None, repo=None,

Function _make_request has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    def _make_request(self, reqmeth, url, *args, **kwargs):
        # copy base request options and update with any keyword args
        rqst_options = self.request_options.copy()
        rqst_options.update(kwargs)
        start = time.time()

• Read up
  Read up

Function _raw_datastream has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

def _raw_datastream(request, pid, dsid, repo=None, headers=None,
       as_of_date=None):
    '''Version of :meth:`raw_datastream` without conditionals, for use
    in class-based views or elsewhere.'''
    if repo is None:

• Read up
  Read up

Function __init__ has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    def __init__(self, response, content=None):
        # init params:
        #  response = HttpResponse with the error information
        #  content = optional content of the response body, if it needed to be read
        #            to determine what kind of exception to raise

• Read up
  Read up

Function __init__ has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    def __init__(self, api, pid=None, create=False, default_pidspace=None):
        self.api = api
        self.dscache = {}       # accessed by DatastreamDescriptor to store and cache datastreams
        self.relcache = {}      # used by Relation to store and cache related objects
        self._risearch = None

• Read up
  Read up

Function process_class has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    def process_class(self, cls):
        try:
            ContentModel.for_class(cls, self.repo)
        except ValueError as v:
            # for_class raises a ValueError when a class has >1

• Read up
  Read up

Function _query has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

    def _query(self, format, http_args, flush=None):
        # if flush parameter was not specified, use class setting
        if flush is None:
            flush = self.RISEARCH_FLUSH_ON_QUERY
        http_args['flush'] = 'true' if flush else 'false'

• Read up
  Read up

Function sync_object has 8 arguments (exceeds 4 allowed). Consider refactoring.

Open

def sync_object(src_obj, dest_repo, export_context='migrate',

Function _store_api_info has 8 arguments (exceeds 4 allowed). Consider refactoring.

Open

    def _store_api_info(self, sender, time_taken=0, method=None, url=None,