added parameter support in format json for custom_start

Author: obhodny

qencode/custom_params.py

@@ -127,7 +127,7 @@ def prepare_params(self):
     query = dict(query=self.params)
     try:
       self.query = json.dumps(query, cls=MyEncoder, encoding='utf-8')
-    except BaseException as e:
+    except Exception as e:
       self.error = True
       self.message = repr(e)
 

qencode/task.py

@@ -112,25 +112,39 @@ def custom_start(self, params,  **kwargs):
           :return: None
 
     """
-    query_obj = Query()
-    query_obj.params = params
-    query_obj.validate_params()
-    if query_obj.error:
-      self.error = query_obj.error
-      self.message = query_obj.message
-      return
-
-    query_obj.prepare_params()
-    if query_obj.error:
-      self.error = query_obj.error
-      self.message = query_obj.message
-
-    if not self.error:
-      self._create_task(1)
-      data = self._prepare_data2(query_obj.query, **kwargs)
-
-      if not self.error and self.task_token:
-        self._start_encode('start_encode2', data)
+    if params is not None:
+      query_obj = Query()
+      query_obj.params = params
+      query_obj.validate_params()
+      if query_obj.error:
+        self.error = query_obj.error
+        self.message = query_obj.message
+        return
+
+      query_obj.prepare_params()
+      if query_obj.error:
+        self.error = query_obj.error
+        self.message = query_obj.message
+
+      if not self.error:
+        self._create_task(1)
+        data = self._prepare_data2(query_obj.query, **kwargs)
+
+        if not self.error and self.task_token:
+          self._start_encode('start_encode2', data)
+
+    elif kwargs.get('query') is not None:
+      query = kwargs.get('query')      
+      if not self.error:
+        self._create_task(1)
+        data = self._prepare_data2(query, **kwargs)
+        print data
+
+        if not self.error and self.task_token:
+          self._start_encode('start_encode2', data)
+    else:
+      self.error = True
+      self.mesage = 'params or query is required'
 
 
   def status(self):