Avoid too many return statements within this function.

Open

        return Job.load(result)

Avoid too many return statements within this function.

Open

        return False

Avoid too many return statements within this function.

Open

                    return True

Avoid too many return statements within this function.

Open

        return False

Avoid too many return statements within this function.

Open

        return True

Avoid too many return statements within this function.

Open

    return noop

Avoid too many return statements within this function.

Open

    return True

Avoid too many return statements within this function.

Open

            return self.create_el(payload)

Avoid too many return statements within this function.

Open

        return 'Parallel failed: update doc ' + str(job['_id']) + ' resulted modified ' + str(result.modified_count)

Function get_status has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def get_status(self):
        devices = self.storage.get_all_el(None, None, None)
        response = {}
        now = dt.datetime.now()
        for d in devices:

• Read up
  Read up

Function lintSchema has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

SchemaLinter.prototype.lintSchema = function(linters, schema, filename) {
    var results = [];

    if( schema['x-lint'] === false ) {
        return results;

• Read up
  Read up

Function join_user_info has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def join_user_info(results):
        """
        Given a list of containers, adds avatar and name context to each member of the permissions and notes lists
        """

• Read up
  Read up

Function _propagate_permissions has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def _propagate_permissions(self, cont_name, _id, query=None, update=None):
        """
        method to propagate permissions from a container/group to its sessions and acquisitions
        """
        if cont_name == 'groups':

• Read up
  Read up

Function get has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def get(self, cid):
        """List rules"""

        projection = None

• Read up
  Read up

Function validate_gear_config has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

def validate_gear_config(gear, config_):
    if len(gear.get('manifest', {}).get('config', {})) > 0:
        invocation = gear_tools.derive_invocation_schema(gear['manifest'])
        ci = gear_tools.isolate_config_invocation(invocation)
        validator = Draft4Validator(ci)

• Read up
  Read up

Function check_state has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

def check_state(batch_id):
    """
    Returns state of batch based on state of each of its jobs
    are complete or failed
    """

• Read up
  Read up

Function get_statistics has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def get_statistics(tags=None, last=None, unique=False, all_flag=False):
        """
        Return a variety of interesting information about the job queue.
        """

• Read up
  Read up

Function build has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def build(self):
        query = {}

        if self.start_date or self.end_date:
            query['created'] = {}

• Read up
  Read up

Function get_all_for_user has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def get_all_for_user(self, cont_name, uid):
        self.config = self.container_handler_configurations[cont_name]
        self.storage = self.config['storage']
        projection = self.config['list_projection']
        # select which permission filter will be applied to the list of results.

• Read up
  Read up

Function list_permission_checker has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

def list_permission_checker(handler):
    def g(exec_op):
        def f(method, query=None, user=None, public=False, projection=None):
            if user and (user['_id'] != handler.uid):
                handler.abort(403, 'User ' + handler.uid + ' may not see the Projects of User ' + user['_id'])

• Read up
  Read up