autopep8: next/

Author: barzamin

next/__init__.py

@@ -1 +0,0 @@
-

next/api/__init__.py

@@ -1 +0,0 @@
-

next/api/api.py

@@ -17,27 +17,30 @@
 app.register_blueprint(dashboard, url_prefix=dashboard_prefix)
 app.register_blueprint(query_page, url_prefix='/query')
 
+
 @app.context_processor
 def inject_global_templatevars():
     return dict(next_git_hash=constants.GIT_HASH,
                 next_version=constants.VERSION)
 
+
 import logging
 import sys
 # Log to standard out. Remember to turn off in production
 app.logger.addHandler(logging.StreamHandler(sys.stdout))
 app.logger.setLevel(logging.DEBUG)
 
-#Handle internal errors using a custom error message
+# Handle internal errors using a custom error message
 import json
+
+
 @app.errorhandler(404)
 def internal_system_error(error):
-    response  = {
-        'meta':{
-            'status':'FAIL',
-            'code':404,
-            'message':'Resource not found'
+    response = {
+        'meta': {
+            'status': 'FAIL',
+            'code': 404,
+            'message': 'Resource not found'
         }
     }
     return json.dumps(response), 404
-

next/api/api_blueprint.py

@@ -35,4 +35,3 @@
 from next.api.resources.participants import Participants
 api_interface.add_resource(Participants,
                            '/experiment/<string:exp_uid>/participants')
-

next/api/api_util.py

@@ -7,10 +7,11 @@
 
 import time
 
+
 def timeit(f):
     """ 
     Utility used to time the duration of code execution. This script can be composed with any other script.
-    
+
     Usage::\n
       def f(n): 
         return n**n  
@@ -25,78 +26,84 @@ def timed(*args, **kw):
         ts = time.time()
         result = f(*args, **kw)
         te = time.time()
-        if type(result)==tuple:
-            return result + ((te-ts),)
+        if type(result) == tuple:
+            return result + ((te - ts),)
         else:
-            return result,(te-ts)
+            return result, (te - ts)
     return timed
 
 
 def attach_meta(response, meta, **kwargs):
     """
     Attach a meta dictionary to a response dictionary.
- 
+
     Inputs: :\n
-    	(dict) response, (dict) meta, (key-value pairs) kwargs - optional messages to add to mets
+        (dict) response, (dict) meta, (key-value pairs) kwargs - optional messages to add to mets
 
     Usage: :\n
     """
     for k, v in kwargs.iteritems():
         meta[k] = v
-        
+
     response["meta"] = meta
     return response
 
+
 verification_error = {
-    'message':'Failed to Authenticate',
-    'status':'FAIL',
-    'code':401
-    }
+    'message': 'Failed to Authenticate',
+    'status': 'FAIL',
+    'code': 401
+}
 
 
 from flask_restful import Api
-import sys, traceback
+import sys
+import traceback
+
+
 class NextBackendApi(Api):
     """
     Subclass of the default Api class of Flask-Restful with custom error handling for 500 requests
-    
+
     All other errors are passed onto the default handle_error.
     """
+
     def handle_error(self, e, **kwargs):
         exc_type, exc_value, tb = sys.exc_info()
-        backend_error = traceback.format_exc(tb)            
-        print "backend_error", backend_error,exc_type, exc_value, tb, traceback.format_exc(tb)
+        backend_error = traceback.format_exc(tb)
+        print "backend_error", backend_error, exc_type, exc_value, tb, traceback.format_exc(tb)
 
         # Catch internal system errors
         code = getattr(e, 'code', 500)
-        if code == 500:      
+        if code == 500:
             response = {
-                'meta':{
+                'meta': {
                     'status': 'FAIL',
                     'code': 500,
                     'message': 'Internal Server Error',
                     'backend_error': backend_error
                 }
             }
-            return self.make_response(response, 500)        
-    	return super(NextBackendApi, self).handle_error(e) 
-
+            return self.make_response(response, 500)
+        return super(NextBackendApi, self).handle_error(e)
 
 
 from flask_restful.reqparse import Argument
 from flask_restful import abort
 
+
 class APIArgument(Argument):
     """
     Subclass of the standard flask restful Argument class to provide a custom meta message.
     Passes up a 400 message if arguments are not correctly parsed.
     """
+
     def __init__(self, *args, **kwargs):
         """
         Pass up the default arguments. 
         """
         super(APIArgument, self).__init__(*args, **kwargs)
-    
+
     def handle_validation_error(self, error, bundle_errors):
         """
         Called when an error is raised while parsing. Aborts the request
@@ -110,12 +117,13 @@ def handle_validation_error(self, error, bundle_errors):
         msg = '[%s]: %s%s' % (self.name, help_str, str(error))
         if bundle_errors:
             return error, msg
-        return abort(400, meta={'message':msg, 'code':400, 'status':'FAIL'})
+        return abort(400, meta={'message': msg, 'code': 400, 'status': 'FAIL'})
 
 
 # Custom Exception types for the api. These should just pass.
 class DatabaseException(Exception):
     pass
 
+
 class BackendConnectionException(Exception):
     pass

next/api/app_handler.py

@@ -21,7 +21,7 @@
     'Error': {
         'message': "There was an error calling this API endpoint ",
         'code': 400,
-        'status':'FAIL'
+        'status': 'FAIL'
     }
 }
 
@@ -31,13 +31,13 @@
 }
 
 
-
 class AppHandler(Resource):
     def post(self, exp_uid, function_name):
         try:
-            post_parser.add_argument('exp_uid', type=str, required=True, help="Experiment ID Required.")
-            post_parser.add_argument('args', type=dict, required=False, help="Experiment args Required.")
-
+            post_parser.add_argument(
+                'exp_uid', type=str, required=True, help="Experiment ID Required.")
+            post_parser.add_argument(
+                'args', type=dict, required=False, help="Experiment args Required.")
 
             # Validate args with post_parser
             args_data = post_parser.parse_args()
@@ -54,7 +54,8 @@ def post(self, exp_uid, function_name):
             # and hit the API with those functions.
             # TODO: test this feature
             # implemented by Scott Sievert, 2016-1-26
-            response_json, didSucceed, message = broker.applyAsync(app_id, exp_uid, function_name, args_json)
+            response_json, didSucceed, message = broker.applyAsync(
+                app_id, exp_uid, function_name, args_json)
 
             if not didSucceed:
                 raise Exception(message)