incubator-ariatosca git commit: tests fix [Forced Update!]

2016-10-31 Thread mxmrlv 
Repository: incubator-ariatosca
Updated Branches:
  refs/heads/ARIA-3-api-for-creating-workflows 71c950ec9 -> 16f76c611 (forced 
update)


tests fix


Project: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/repo
Commit: 
http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/commit/16f76c61
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/tree/16f76c61
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/diff/16f76c61

Branch: refs/heads/ARIA-3-api-for-creating-workflows
Commit: 16f76c6110d0c7d20ee4067a2eddabab19e5fe67
Parents: 3d1c8b1
Author: mxmrlv 
Authored: Mon Oct 31 15:29:16 2016 +0200
Committer: mxmrlv 
Committed: Mon Oct 31 17:59:13 2016 +0200

--
 aria/.pylintrc |  2 +-
 aria/storage/drivers.py|  2 +-
 aria/workflows/api/task_graph.py   |  5 +
 aria/workflows/builtin/workflows.py| 17 ++---
 aria/workflows/core/executor.py|  1 -
 tests/.pylintrc|  6 +++---
 tests/test_logger.py   |  2 +-
 tests/workflows/api/test_task_graph.py |  5 -
 tests/workflows/core/test_executor.py  |  6 +++---
 tox.ini|  4 ++--
 10 files changed, 30 insertions(+), 20 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/16f76c61/aria/.pylintrc
--
diff --git a/aria/.pylintrc b/aria/.pylintrc
index eb188a0..ee27fdb 100644
--- a/aria/.pylintrc
+++ b/aria/.pylintrc
@@ -62,7 +62,7 @@ confidence=
 # --enable=similarities". If you want to run only the classes checker, but have
 # no Warning level messages displayed, use"--disable=all --enable=classes
 # --disable=W"
-disable=import-star-module-level,old-octal-literal,oct-method,print-statement,unpacking-in-except,parameter-unpacking,backtick,old-raise-syntax,old-ne-operator,long-suffix,dict-view-method,dict-iter-method,metaclass-assignment,next-method-called,raising-string,indexing-exception,raw_input-builtin,long-builtin,file-builtin,execfile-builtin,coerce-builtin,cmp-builtin,buffer-builtin,basestring-builtin,apply-builtin,filter-builtin-not-iterating,using-cmp-argument,useless-suppression,range-builtin-not-iterating,suppressed-message,no-absolute-import,old-division,cmp-method,reload-builtin,zip-builtin-not-iterating,intern-builtin,unichr-builtin,reduce-builtin,standarderror-builtin,unicode-builtin,xrange-builtin,coerce-method,delslice-method,getslice-method,setslice-method,input-builtin,round-builtin,hex-method,nonzero-method,map-builtin-not-iterating,redefined-builtin,logging-format-interpolation
+disable=import-star-module-level,old-octal-literal,oct-method,print-statement,unpacking-in-except,parameter-unpacking,backtick,old-raise-syntax,old-ne-operator,long-suffix,dict-view-method,dict-iter-method,metaclass-assignment,next-method-called,raising-string,indexing-exception,raw_input-builtin,long-builtin,file-builtin,execfile-builtin,coerce-builtin,cmp-builtin,buffer-builtin,basestring-builtin,apply-builtin,filter-builtin-not-iterating,using-cmp-argument,useless-suppression,range-builtin-not-iterating,suppressed-message,no-absolute-import,old-division,cmp-method,reload-builtin,zip-builtin-not-iterating,intern-builtin,unichr-builtin,reduce-builtin,standarderror-builtin,unicode-builtin,xrange-builtin,coerce-method,delslice-method,getslice-method,setslice-method,input-builtin,round-builtin,hex-method,nonzero-method,map-builtin-not-iterating,redefined-builtin,logging-format-interpolation,import-error
 
 [REPORTS]
 

http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/16f76c61/aria/storage/drivers.py
--
diff --git a/aria/storage/drivers.py b/aria/storage/drivers.py
index 33b7c00..0ad2f49 100644
--- a/aria/storage/drivers.py
+++ b/aria/storage/drivers.py
@@ -32,7 +32,7 @@ import shutil
 # pylint has an issue with distutils and virtualenvs: 
https://github.com/PyCQA/pylint/issues/73
 import distutils.dir_util  
 # pylint: disable=no-name-in-module, import-error
 from functools import partial
-from billiard import RLock
+from multiprocessing import RLock
 
 import jsonpickle
 

http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/16f76c61/aria/workflows/api/task_graph.py
--
diff --git a/aria/workflows/api/task_graph.py b/aria/workflows/api/task_graph.py
index 20b0a50..3d75c10 100644
--- a/aria/workflows/api/task_graph.py
+++ b/aria/workflows/api/task_graph.py
@@ -276,6 +276,11 @@ class TaskGraph(object):
 
 @_filter_out_empty_tasks
 def sequence(self, *tasks):
+"""
+Create and insert

incubator-ariatosca git commit: tests fix [Forced Update!]

2016-10-31 Thread mxmrlv 
Repository: incubator-ariatosca
Updated Branches:
  refs/heads/ARIA-3-api-for-creating-workflows d07560149 -> 71c950ec9 (forced 
update)


tests fix


Project: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/repo
Commit: 
http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/commit/71c950ec
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/tree/71c950ec
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/diff/71c950ec

Branch: refs/heads/ARIA-3-api-for-creating-workflows
Commit: 71c950ec9a6a4fc05eac05d117099d9a3d429bed
Parents: 3d1c8b1
Author: mxmrlv 
Authored: Mon Oct 31 15:29:16 2016 +0200
Committer: mxmrlv 
Committed: Mon Oct 31 15:47:25 2016 +0200

--
 aria/storage/drivers.py   | 2 +-
 aria/workflows/core/executor.py   | 5 ++---
 tests/test_logger.py  | 2 +-
 tests/workflows/core/test_executor.py | 6 +++---
 4 files changed, 7 insertions(+), 8 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/71c950ec/aria/storage/drivers.py
--
diff --git a/aria/storage/drivers.py b/aria/storage/drivers.py
index 33b7c00..0ad2f49 100644
--- a/aria/storage/drivers.py
+++ b/aria/storage/drivers.py
@@ -32,7 +32,7 @@ import shutil
 # pylint has an issue with distutils and virtualenvs: 
https://github.com/PyCQA/pylint/issues/73
 import distutils.dir_util  
 # pylint: disable=no-name-in-module, import-error
 from functools import partial
-from billiard import RLock
+from multiprocessing import RLock
 
 import jsonpickle
 

http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/71c950ec/aria/workflows/core/executor.py
--
diff --git a/aria/workflows/core/executor.py b/aria/workflows/core/executor.py
index 1abecac..0a5cd67 100644
--- a/aria/workflows/core/executor.py
+++ b/aria/workflows/core/executor.py
@@ -18,7 +18,7 @@ Executors for workflow tasks
 """
 
 import threading
-import billiard as multiprocessing
+import multiprocessing
 import Queue
 
 import jsonpickle
@@ -134,8 +134,7 @@ class MultiprocessExecutor(BaseExecutor):
 self._listener_thread = threading.Thread(target=self._listener)
 self._listener_thread.daemon = True
 self._listener_thread.start()
-self._pool = multiprocessing.Pool(processes=pool_size,
-  maxtasksperchild=1)
+self._pool = multiprocessing.Pool(processes=pool_size)
 
 def execute(self, task):
 self._tasks[task.id] = task

http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/71c950ec/tests/test_logger.py
--
diff --git a/tests/test_logger.py b/tests/test_logger.py
index 7891dd6..37731bb 100644
--- a/tests/test_logger.py
+++ b/tests/test_logger.py
@@ -80,7 +80,7 @@ def test_create_file_log_handler():
 assert handler.baseFilename == temp_file.name
 assert handler.maxBytes == 5 * 1000 * 1024
 assert handler.backupCount == 10
-assert handler.delay is True
+assert handler.stream is None
 assert handler.level == logging.DEBUG
 assert handler.formatter == _default_file_formatter
 

http://git-wip-us.apache.org/repos/asf/incubator-ariatosca/blob/71c950ec/tests/workflows/core/test_executor.py
--
diff --git a/tests/workflows/core/test_executor.py 
b/tests/workflows/core/test_executor.py
index 27cb2ad..bfb19d1 100644
--- a/tests/workflows/core/test_executor.py
+++ b/tests/workflows/core/test_executor.py
@@ -50,7 +50,7 @@ class TestExecutor(object):
 assert task_with_inputs.states == ['start', 'failure']
 assert isinstance(failing_task.exception, TestException)
 assert isinstance(task_with_inputs.exception, TestException)
-assert task_with_inputs.exception.message == expected_value
+assert str(task_with_inputs.exception) == expected_value
 assertion()
 
 def setup_method(self):
@@ -62,7 +62,7 @@ class TestExecutor(object):
 events.start_task_signal.disconnect(start_handler)
 events.on_success_task_signal.disconnect(success_handler)
 events.on_failure_task_signal.disconnect(failure_handler)
-if self.executor:
+if hasattr(self, 'executor'):
 self.executor.close()
 
 
@@ -97,7 +97,7 @@ class MockTask(object):
 self.exception = None
 self.id = str(uuid.uuid4())
 name = func.__name__
-operation = 'tests.workflows.test_executor.{name}'.format(name=name)
+operation =