Function exports has 123 lines of code (exceeds 25 allowed). Consider refactoring.

Open

module.exports = function(grunt) {
    loadTasks(grunt);
    grunt.task.loadTasks('support/tasks/');

    grunt.task.registerTask('createBuildDir', function() {

Function generate_request has a Cognitive Complexity of 33 (exceeds 5 allowed). Consider refactoring.

Open

    def generate_request(self, gear):
        """
        Generate the job's request, save it to the class, and return it

        Parameters

• Read up
  Read up

Function default_container has a Cognitive Complexity of 31 (exceeds 5 allowed). Consider refactoring.

Open

def default_container(handler, container=None, target_parent_container=None):
    """
    This is the default permissions checker generator.
    The resulting permissions checker modifies the exec_op method by checking the user permissions
    on the container before actually executing this method.

• Read up
  Read up

Function _build_month_report has a Cognitive Complexity of 31 (exceeds 5 allowed). Consider refactoring.

Open

    def _build_month_report(self, base_query):
        """
        Builds a usage report for file size, session count and gear execution count
        Aggregates this information by month.

• Read up
  Read up

File refererhandler.py has 355 lines of code (exceeds 250 allowed). Consider refactoring.

Open

"""
Module defining RefererHandler and it's subclasses. RefererHandler
generalizes the handling of documents that are not part of the container
hierarchy, are always associated with (referencing) a parent container,
and are stored in their own collection instead of an embedded list on the

Function eval_match has a Cognitive Complexity of 30 (exceeds 5 allowed). Consider refactoring.

Open

def eval_match(match_type, match_param, file_, container, regex=False):
    """
    Given a match entry, return if the match succeeded.
    """

• Read up
  Read up

Function undelete has a Cognitive Complexity of 30 (exceeds 5 allowed). Consider refactoring.

Open

def undelete(cont_name, cont_id, filename=None, include_parents=False, always_propagate=False):
    if cont_name not in cont_names:
        raise ValueError('Invalid cont_name "{}" (must be one of {})'.format(cont_name, cont_names_str))
    if not bson.ObjectId.is_valid(cont_id):
        raise ValueError('Invalid cont_id "{}" (must be parseable ObjectId)'.format(cont_id))

• Read up
  Read up

File download.py has 345 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import bson
import pytz
import os.path
import tarfile
import datetime

File jobs.py has 344 lines of code (exceeds 250 allowed). Consider refactoring.

Open

"""
Jobs
"""

import bson

Function post has a Cognitive Complexity of 28 (exceeds 5 allowed). Consider refactoring.

Open

    def post(self):
        """
        Create a batch job proposal, insert as 'pending' if there are matched containers
        """

• Read up
  Read up

Function get_config has a Cognitive Complexity of 28 (exceeds 5 allowed). Consider refactoring.

Open

    def get_config(self, _id):
        """Get a job's config"""
        j = Job.get(_id)
        c = j.config
        if c is None:

• Read up
  Read up

Function upgrade_to_16 has a Cognitive Complexity of 28 (exceeds 5 allowed). Consider refactoring.

Open

def upgrade_to_16():
    """
    Fixes file.size sometimes being a floating-point rather than integer.
    """

• Read up
  Read up

Function check has a Cognitive Complexity of 28 (exceeds 5 allowed). Consider refactoring.

Open

    def check(self):
        self.requireTarget()

        # Check that required state exists
        if self.context.get('job_id'):

• Read up
  Read up

File base.py has 333 lines of code (exceeds 250 allowed). Consider refactoring.

Open

import base64
import datetime
import jsonschema
import os
import pymongo

Function update_el has a Cognitive Complexity of 27 (exceeds 5 allowed). Consider refactoring.

Open

    def update_el(self, _id, payload, unset_payload=None, recursive=False, r_payload=None, replace_metadata=False):
        session = self.get_container(_id)
        if session is None:
            raise APINotFoundException('Could not find session {}'.format(_id))

• Read up
  Read up

Function draft4ToOpenApi2 has a Cognitive Complexity of 26 (exceeds 5 allowed). Consider refactoring.

Open

SchemaTranspiler.prototype.draft4ToOpenApi2 = function(schema, defs, id) {
    var ref, defname;

    // Drop the $schema property, and make a copy
    schema = _.omit(schema, OMITTED_PROPERTIES);

• Read up
  Read up

Function log_user_access has a Cognitive Complexity of 26 (exceeds 5 allowed). Consider refactoring.

Open

    def log_user_access(self, access_type, cont_name=None, cont_id=None, filename=None, multifile=False, origin_override=None):

        if not config.get_item('core', 'access_log_enabled'):
            return

• Read up
  Read up

File queue.py has 316 lines of code (exceeds 250 allowed). Consider refactoring.

Open

"""
A simple FIFO queue for jobs.
"""

import bson

Function _append_targets has a Cognitive Complexity of 25 (exceeds 5 allowed). Consider refactoring.

Open

    def _append_targets(self, targets, cont_name, container, prefix, total_size, total_cnt, data_path, filters):
        inputs = [('input', f) for f in container.get('inputs', [])]
        outputs = [('output', f) for f in container.get('files', [])]
        for file_group, f in inputs + outputs:
            if filters:

• Read up
  Read up

Function resolveRefs has a Cognitive Complexity of 24 (exceeds 5 allowed). Consider refactoring.

Open

Schemas.prototype.resolveRefs = function(relpath, obj, jsonpath) {
    var $ref, parts, curpath, actualpath, pathpart;
    // Ignore examples
    if( jsonpath && jsonpath[jsonpath.length-1] === 'example' ) {
        return obj;

• Read up
  Read up