ariatosca-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ran Ziv (JIRA)" <j...@apache.org>
Subject [jira] [Created] (ARIA-315) ProcessExecutor concurrent modifications test error
Date Tue, 11 Jul 2017 13:26:00 GMT
Ran Ziv created ARIA-315:
----------------------------

             Summary: ProcessExecutor concurrent modifications test error
                 Key: ARIA-315
                 URL: https://issues.apache.org/jira/browse/ARIA-315
             Project: AriaTosca
          Issue Type: Bug
            Reporter: Ran Ziv
            Priority: Minor


The {{test_process_executor_concurrent_modifications}} module includes a test which fails
sporadically. See stack trace below:

{code}
________________ test_concurrent_modification_on_task_succeeded ________________
context = WorkflowContext(deployment_id=1, workflow_name=test_workflow, execution_id=1)
executor = <aria.orchestrator.workflows.executor.process.ProcessExecutor object at 0x7fc3cc88a550>
lock_files = ('/tmp/pytest-of-travis/pytest-0/test_concurrent_modification_o0/first_lock_file',
'/tmp/pytest-of-travis/pytest-0/test_concurrent_modification_o0/second_lock_file')
dataholder = <tests.helpers.FilesystemDataHolder object at 0x7fc3cc830190>
    def test_concurrent_modification_on_task_succeeded(context, executor, lock_files, dataholder):
>       _test(context, executor, lock_files, _test_task_succeeded, dataholder, expected_failure=False)
tests/orchestrator/workflows/executor/test_process_executor_concurrent_modifications.py:42:

_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
context = WorkflowContext(deployment_id=1, workflow_name=test_workflow, execution_id=1)
executor = <aria.orchestrator.workflows.executor.process.ProcessExecutor object at 0x7fc3cc88a550>
lock_files = ('/tmp/pytest-of-travis/pytest-0/test_concurrent_modification_o0/first_lock_file',
'/tmp/pytest-of-travis/pytest-0/test_concurrent_modification_o0/second_lock_file')
func = <function _test_task_succeeded at 0x7fc3fa8597d0>
dataholder = <tests.helpers.FilesystemDataHolder object at 0x7fc3cc830190>
expected_failure = False
    def _test(context, executor, lock_files, func, dataholder, expected_failure):
        def _node(ctx):
            return ctx.model.node.get_by_name(mock.models.DEPENDENCY_NODE_NAME)
    
        interface_name, operation_name = mock.operations.NODE_OPERATIONS_INSTALL[0]
    
        key = 'key'
        first_value = 'value1'
        second_value = 'value2'
        arguments = {
            'lock_files': lock_files,
            'key': key,
            'first_value': first_value,
            'second_value': second_value,
            'holder_path': dataholder.path
        }
    
        node = _node(context)
        interface = mock.models.create_interface(
            node.service,
            interface_name,
            operation_name,
            operation_kwargs=dict(function='{0}.{1}'.format(__name__, func.__name__),
                                  arguments=arguments)
        )
        node.interfaces[interface.name] = interface
        context.model.node.update(node)
    
        @workflow
        def mock_workflow(graph, **_):
            graph.add_tasks(
                api.task.OperationTask(
                    node,
                    interface_name=interface_name,
                    operation_name=operation_name,
                    arguments=arguments),
                api.task.OperationTask(
                    node,
                    interface_name=interface_name,
                    operation_name=operation_name,
                    arguments=arguments)
            )
    
        signal = events.on_failure_task_signal
        with events_collector(signal) as collected:
            try:
                execute_workflow(mock_workflow, context, executor)
            except ExecutorException:
                pass
    
        props = _node(context).attributes
>       assert dataholder['invocations'] == 2
E       assert 1 == 2
tests/orchestrator/workflows/executor/test_process_executor_concurrent_modifications.py:112:
AssertionError
{code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message