Cleaning up some flake8 errors, pyflakes in this case

awx/api/permissions.py

@@ -12,8 +12,8 @@ from rest_framework.exceptions import PermissionDenied
 from rest_framework import permissions
 
 # AWX
-from awx.main.access import *
+from awx.main.access import * # noqa
-from awx.main.models import *
+from awx.main.models import * # noqa
 from awx.main.utils import get_object_or_400
 
 logger = logging.getLogger('awx.api.permissions')
@@ -45,7 +45,7 @@ class ModelAccessPermission(permissions.BasePermission):
 
     def check_post_permissions(self, request, view, obj=None):
         if hasattr(view, 'parent_model'):
-            parent_obj = get_object_or_400(view.parent_model, pk=view.kwargs['pk'])
+            get_object_or_400(view.parent_model, pk=view.kwargs['pk'])
             return True
         elif getattr(view, 'is_job_start', False):
             if not obj:

awx/api/renderers.py

@@ -1,9 +1,6 @@
 # Copyright (c) 2014 AnsibleWorks, Inc.
 # All Rights Reserved.
 
-# Django
-from django.utils.datastructures import SortedDict
-
 # Django REST Framework
 from rest_framework import renderers
 
@@ -36,11 +33,6 @@ class BrowsableAPIRenderer(renderers.BrowsableAPIRenderer):
 
     def get_context(self, data, accepted_media_type, renderer_context):
         context = super(BrowsableAPIRenderer, self).get_context(data, accepted_media_type, renderer_context)
-        # FIXME: Sort headers / preserve sorting?
-        #response_headers = SortedDict(context['response'].items())
-        #if 'Content-Type' in context['response_headers']:
-        #    response_headers['Content-Type'] = context['response_headers']['Content-Type']
-        #context['response_headers'] = response_headers
         return context
 
 class PlainTextRenderer(renderers.BaseRenderer):

awx/api/tests/__init__.py

@@ -3,5 +3,5 @@
 
 from __future__ import absolute_import
 
-from .decorator_paginated import *
+from .decorator_paginated import PaginatedDecoratorTests # noqa
-from .job_tasks import *
+from .job_tasks import JobTasksTests # noqa

awx/api/tests/job_tasks.py

@@ -1,20 +1,10 @@
 # Copyright (c) 2014 Ansible, Inc.
 # All Rights Reserved.
 
-from datetime import datetime
-
 from django.conf import settings
-from django.contrib.auth.models import User
-from django.core.urlresolvers import reverse
 from django.test import LiveServerTestCase
 from django.test.utils import override_settings
 
-from rest_framework.test import APIClient
-
-import mock
-
-from awx.api.views import JobJobTasksList
-from awx.main.models import Job, JobTemplate, JobEvent
 from awx.main.tests.jobs import BaseJobTestMixin
 
 

awx/lib/compat.py

@@ -10,6 +10,7 @@ try:
 except ImportError:
     from django.utils.html import conditional_escape
     from django.utils.safestring import mark_safe
+
     def format_html(format_string, *args, **kwargs):
         args_safe = map(conditional_escape, args)
         kwargs_safe = dict([(k, conditional_escape(v)) for (k, v) in
@@ -21,11 +22,12 @@ try:
 except ImportError:
     import logging
     from django.conf import settings
+
     class RequireDebugTrue(logging.Filter):
         def filter(self, record):
             return settings.DEBUG
 
 try:
-    from django.utils.text import slugify
+    from django.utils.text import slugify # noqa
 except ImportError:
-    from django.template.defaultfilters import slugify
+    from django.template.defaultfilters import slugify # noqa

awx/main/access.py

@@ -14,8 +14,8 @@ from django.contrib.auth.models import User
 from rest_framework.exceptions import ParseError, PermissionDenied
 
 # AWX
-from awx.main.utils import *
+from awx.main.utils import * # noqa
-from awx.main.models import *
+from awx.main.models import * # noqa
 from awx.main.task_engine import TaskSerializer
 
 __all__ = ['get_user_queryset', 'check_user_access']
@@ -672,7 +672,6 @@ class ProjectAccess(BaseAccess):
                        Q(organizations__admins__in=[self.user], organizations__active=True) |
                        Q(organizations__users__in=[self.user], organizations__active=True) |
                        Q(teams__in=team_ids))
-        allowed = [PERM_INVENTORY_DEPLOY, PERM_INVENTORY_CHECK]
         allowed_deploy = [PERM_JOBTEMPLATE_CREATE, PERM_INVENTORY_DEPLOY]
         allowed_check = [PERM_JOBTEMPLATE_CREATE, PERM_INVENTORY_DEPLOY, PERM_INVENTORY_CHECK]
 
@@ -854,7 +853,6 @@ class JobTemplateAccess(BaseAccess):
         org_admin_qs = base_qs.filter(
             project__organizations__admins__in=[self.user]
         )
-        allowed = [PERM_INVENTORY_CHECK, PERM_INVENTORY_DEPLOY]
         allowed_deploy = [PERM_JOBTEMPLATE_CREATE, PERM_INVENTORY_DEPLOY]
         allowed_check = [PERM_JOBTEMPLATE_CREATE, PERM_INVENTORY_DEPLOY, PERM_INVENTORY_CHECK]
 
@@ -1052,21 +1050,8 @@ class JobAccess(BaseAccess):
         org_admin_qs = base_qs.filter(
             project__organizations__admins__in=[self.user]
         )
-        allowed = [PERM_INVENTORY_CHECK, PERM_INVENTORY_DEPLOY]
-
         allowed_deploy = [PERM_JOBTEMPLATE_CREATE, PERM_INVENTORY_DEPLOY]
         allowed_check = [PERM_JOBTEMPLATE_CREATE, PERM_INVENTORY_DEPLOY, PERM_INVENTORY_CHECK]
-
-        # perm_qs = base_qs.filter(
-        #     Q(inventory__permissions__user=self.user) | Q(inventory__permissions__team__users__in=[self.user]),
-        #     Q(project__permissions__user=self.user) | Q(project__permissions__team__users__in=[self.user]),
-        #     inventory__permissions__permission_type__in=allowed,
-        #     project__permissions__permission_type__in=allowed,
-        #     inventory__permissions__active=True,
-        #     project__permissions__active=True,
-        #     inventory__permissions__pk=F('project__permissions__pk'),
-        # )
-
         team_ids = set(Team.objects.filter(users__in=[self.user]).values_list('id', flat=True))
 
         deploy_permissions_ids = set(Permission.objects.filter(

awx/main/fields.py

@@ -4,8 +4,6 @@
 # Django
 from django.db import models
 from django.db.models.fields.related import SingleRelatedObjectDescriptor
-from django.utils.translation import ugettext_lazy as _
-
 
 # South
 from south.modelsinspector import add_introspection_rules

awx/main/managers.py

@@ -5,7 +5,6 @@ import sys
 
 from django.conf import settings
 from django.db import models
-from django.utils.functional import cached_property
 
 
 class HostManager(models.Manager):

awx/main/middleware.py

@@ -1,22 +1,19 @@
 # Copyright (c) 2014 Ansible, Inc.
 # All Rights Reserved.
 
-import json
 import logging
 import threading
 import uuid
-import urllib2
 
-from django.conf import settings
+from django.contrib.auth.models import User
-from django.contrib.auth.models import User, AnonymousUser
+from django.db.models.signals import post_save
-from django.db.models.signals import pre_save, post_save
 from django.db import IntegrityError
 from django.http import HttpResponseRedirect
 from django.template.response import TemplateResponse
 from django.utils.functional import curry
 
 from awx import __version__ as version
-from awx.main.models import ActivityStream, AuthToken, Instance
+from awx.main.models import ActivityStream, Instance
 
 
 logger = logging.getLogger('awx.main.middleware')
@@ -50,7 +47,7 @@ class ActivityStreamMiddleware(threading.local):
                 instance.actor = drf_user
                 try:
                     instance.save(update_fields=['actor'])
-                except IntegrityError, e:
+                except IntegrityError:
                     logger.debug("Integrity Error saving Activity Stream instance for id : " + str(instance.id))
             # else:
             #     obj1_type_actual = instance.object1_type.split(".")[-1]

awx/main/queue.py

@@ -2,7 +2,6 @@
 # All Rights Reserved.
 
 import json
-import time
 
 from redis import StrictRedis
 

awx/main/signals.py

@@ -17,8 +17,8 @@ from crum import get_current_request
 from crum.signals import current_user_getter
 
 # AWX
-from awx.main.models import *
+from awx.main.models import * # noqa
-from awx.api.serializers import *
+from awx.api.serializers import * # noqa
 from awx.main.utils import model_instance_diff, model_to_dict, camelcase_to_underscore, emit_websocket_notification
 from awx.main.utils import ignore_inventory_computed_fields, ignore_inventory_group_removal, _inventory_updates
 from awx.main.tasks import update_inventory_computed_fields
@@ -35,14 +35,6 @@ def emit_job_event_detail(sender, **kwargs):
     instance = kwargs['instance']
     created = kwargs['created']
     if created:
-        if instance.host is not None:
-            host_id = instance.host.id
-        else:
-            host_id = None
-        if instance.parent is not None:
-            parent_id = instance.parent.id
-        else:
-            parent_id = None
         event_serialized = JobEventSerializer(instance).data
         event_serialized['id'] = instance.id
         event_serialized["created"] = event_serialized["created"].isoformat()

awx/main/storage.py

@@ -2,12 +2,10 @@
 # All Rights Reserved.
 
 import base64
-import os
 from cStringIO import StringIO
 
 from django.core import files
 from django.core.files.storage import Storage
-from django.core.urlresolvers import reverse
 
 
 class DatabaseStorage(Storage):

awx/main/tasks.py

@@ -14,7 +14,6 @@ import pipes
 import re
 import shutil
 import stat
-import subprocess
 import tempfile
 import time
 import traceback
@@ -28,7 +27,6 @@ import pexpect
 
 # Celery
 from celery import Task, task
-from djcelery.models import PeriodicTask
 
 # Django
 from django.conf import settings
@@ -38,7 +36,7 @@ from django.utils.timezone import now
 
 # AWX
 from awx.main.constants import CLOUD_PROVIDERS
-from awx.main.models import *
+from awx.main.models import * # noqa
 from awx.main.queue import FifoQueue
 from awx.main.utils import (get_ansible_version, decrypt_field, update_scm_url,
                             ignore_inventory_computed_fields, emit_websocket_notification,
@@ -71,7 +69,8 @@ def tower_periodic_scheduler(self):
         try:
             last_run = dateutil.parser.parse(fd.read())
             return last_run
-        except Exception, e:
+        except Exception:
+            #TODO: LOG
             return None
 
     def write_last_run(last_run):

awx/main/urls.py

@@ -1,7 +1,6 @@
 # Copyright (c) 2014 AnsibleWorks, Inc.
 # All Rights Reserved.
 
-from django.conf import settings
+from django.conf.urls import patterns
-from django.conf.urls import *
 
 urlpatterns = patterns()

awx/main/utils.py

@@ -276,15 +276,6 @@ def model_instance_diff(old, new, serializer_mapping=None):
 
     diff = {}
 
-    if old is not None and new is not None:
-        fields = set(old._meta.fields + new._meta.fields)
-    elif old is not None:
-        fields = set(old._meta.fields)
-    elif new is not None:
-        fields = set(new._meta.fields)
-    else:
-        fields = set()
-
     if serializer_mapping is not None and new.__class__ in serializer_mapping:
         serializer_actual = serializer_mapping[new.__class__]()
         allowed_fields = [x for x in serializer_actual.fields if not serializer_actual.fields[x].read_only] + ['id']
@@ -421,7 +412,7 @@ def check_proot_installed():
     try:
         proc = subprocess.Popen(cmd, stdout=subprocess.PIPE,
                                 stderr=subprocess.PIPE)
-        result = proc.communicate()
+        proc.communicate()
         return bool(proc.returncode == 0)
     except (OSError, ValueError):
         return False

awx/main/views.py

@@ -2,9 +2,7 @@
 # All Rights Reserved.
 
 # Django
-from django.conf import settings
 from django.shortcuts import render
-from django.template import RequestContext
 from django.utils.safestring import mark_safe
 
 def handle_error(request, status=404, **kwargs):