Skip to main content
Ctrl+K

pypushflow 1.3.0 documentation

  • Concurrency
  • API documentation
  • gitlab
  • pypi
  • Concurrency
  • API documentation
  • gitlab
  • pypi

Section Navigation

  • pypushflow
    • pypushflow.AbstractActor
      • pypushflow.AbstractActor.AbstractActor
    • pypushflow.ActorInterface
      • pypushflow.ActorInterface.ActorInterface
    • pypushflow.AsyncExecute
    • pypushflow.ErrorHandler
      • pypushflow.ErrorHandler.ErrorHandler
    • pypushflow.ForkActor
      • pypushflow.ForkActor.ForkActor
    • pypushflow.JoinActor
      • pypushflow.JoinActor.JoinActor
    • pypushflow.PythonActor
      • pypushflow.PythonActor.PythonActor
    • pypushflow.RequestStatus
      • pypushflow.RequestStatus.RequestStatus
    • pypushflow.RouterActor
      • pypushflow.RouterActor.RouterActor
    • pypushflow.StartActor
      • pypushflow.StartActor.StartActor
    • pypushflow.StopActor
      • pypushflow.StopActor.StopActor
    • pypushflow.Submodel
      • pypushflow.Submodel.Port
      • pypushflow.Submodel.Submodel
    • pypushflow.ThreadCounter
      • pypushflow.ThreadCounter.ThreadCounter
    • pypushflow.ThreadCountingActor
      • pypushflow.ThreadCountingActor.callback_with_end_thread
      • pypushflow.ThreadCountingActor.with_thread_context
      • pypushflow.ThreadCountingActor.ThreadCountingActor
    • pypushflow.Workflow
      • pypushflow.Workflow.Workflow
    • pypushflow.concurrent
      • pypushflow.concurrent.base
        • pypushflow.concurrent.base.BasePool
      • pypushflow.concurrent.exceptions
        • pypushflow.concurrent.exceptions.serialize_exception
      • pypushflow.concurrent.factory
        • pypushflow.concurrent.factory.get_pool
      • pypushflow.concurrent.interrupt
        • pypushflow.concurrent.interrupt.StopPypushflowTask
        • pypushflow.concurrent.interrupt.process
      • pypushflow.concurrent.multiprocessing
        • pypushflow.concurrent.multiprocessing.MProcessPool
      • pypushflow.concurrent.ndmultiprocessing
        • pypushflow.concurrent.ndmultiprocessing.NProcessPool
      • pypushflow.concurrent.ndprocess
        • pypushflow.concurrent.ndprocess.NdProcessPool
      • pypushflow.concurrent.non_daemonic
        • pypushflow.concurrent.non_daemonic.get_context
        • pypushflow.concurrent.non_daemonic.ForkNonDaemonicContext
        • pypushflow.concurrent.non_daemonic.ForkNonDaemonicProcess
        • pypushflow.concurrent.non_daemonic.ForkServerNonDaemonicContext
        • pypushflow.concurrent.non_daemonic.ForkServerNonDaemonicProcess
        • pypushflow.concurrent.non_daemonic.SpawnNonDaemonicContext
        • pypushflow.concurrent.non_daemonic.SpawnNonDaemonicProcess
      • pypushflow.concurrent.process
        • pypushflow.concurrent.process.ProcessPool
      • pypushflow.concurrent.scaling
        • pypushflow.concurrent.scaling.ScalingPool
      • pypushflow.concurrent.thread
        • pypushflow.concurrent.thread.ThreadPool
    • pypushflow.logutils
      • pypushflow.logutils.basicConfig
      • pypushflow.logutils.PyPushflowLoggedObject
    • pypushflow.persistence
      • pypushflow.persistence.init_db_client
      • pypushflow.persistence.register_actorinfo_filter
      • pypushflow.persistence.besdb
        • pypushflow.persistence.besdb.BesWorkflowDbClient
      • pypushflow.persistence.dummy
        • pypushflow.persistence.dummy.DummyWorkflowDbClient
      • pypushflow.persistence.interface
        • pypushflow.persistence.interface.WorkflowDbClient
      • pypushflow.persistence.mongita
        • pypushflow.persistence.mongita.MemoryWorkflowDbClient
      • pypushflow.persistence.mongo
        • pypushflow.persistence.mongo.MongoWorkflowDbClient
      • pypushflow.persistence.pymongo
        • pypushflow.persistence.pymongo.PyMongoWorkflowDbClient
    • pypushflow.stop_workflows
      • pypushflow.stop_workflows.stop_on_signals_context
      • pypushflow.stop_workflows.StopPypushflowWorkflow
    • pypushflow.tests
      • pypushflow.tests.actorinfo_filter
      • pypushflow.tests.concurrent
        • pypushflow.tests.concurrent.filter_combinations
        • pypushflow.tests.concurrent.test_apply_async
        • pypushflow.tests.concurrent.test_interrupt
        • pypushflow.tests.concurrent.test_nesting
        • pypushflow.tests.concurrent.utils
      • pypushflow.tests.conftest
        • pypushflow.tests.conftest.gevent_patched
        • pypushflow.tests.conftest.skip_on_windows
        • pypushflow.tests.conftest.skip_when_gevent
        • pypushflow.tests.conftest.workflow_cleanup
      • pypushflow.tests.tasks
        • pypushflow.tests.tasks.pythonActor1
        • pypushflow.tests.tasks.pythonActor2
        • pypushflow.tests.tasks.pythonActorAdd
        • pypushflow.tests.tasks.pythonActorAdd2
        • pypushflow.tests.tasks.pythonActorAddAndCheck
        • pypushflow.tests.tasks.pythonActorAddWithoutSleep
        • pypushflow.tests.tasks.pythonActorCheck
        • pypushflow.tests.tasks.pythonActorInterrupt
        • pypushflow.tests.tasks.pythonActorSleep
        • pypushflow.tests.tasks.pythonActorTest
        • pypushflow.tests.tasks.pythonErrorHandlerTest
        • pypushflow.tests.tasks.pythonLongExecutionTest
      • pypushflow.tests.test_actors
        • pypushflow.tests.test_actors.TestPythonActor
      • pypushflow.tests.test_persistency
        • pypushflow.tests.test_persistency.besdb_client
        • pypushflow.tests.test_persistency.dummy_client
        • pypushflow.tests.test_persistency.memory_client
        • pypushflow.tests.test_persistency.mock_mongo
        • pypushflow.tests.test_persistency.pymongo_client
        • pypushflow.tests.test_persistency.test_actor_bes
        • pypushflow.tests.test_persistency.test_actor_dummy
        • pypushflow.tests.test_persistency.test_actor_memory
        • pypushflow.tests.test_persistency.test_actor_pymongo
        • pypushflow.tests.test_persistency.test_workflow_bes
        • pypushflow.tests.test_persistency.test_workflow_dummy
        • pypushflow.tests.test_persistency.test_workflow_memory
        • pypushflow.tests.test_persistency.test_workflow_pymongo
      • pypushflow.tests.test_stop_workflow
        • pypushflow.tests.test_stop_workflow.test_stop_signal_workflow
        • pypushflow.tests.test_stop_workflow.test_stop_workflow
        • pypushflow.tests.test_stop_workflow.WorkflowSleep
      • pypushflow.tests.test_threadcounter
        • pypushflow.tests.test_threadcounter.TestThreadCounter
      • pypushflow.tests.test_threadcounteractor
        • pypushflow.tests.test_threadcounteractor.Counter
        • pypushflow.tests.test_threadcounteractor.MyThreadCountingActor
        • pypushflow.tests.test_threadcounteractor.TestThreadCountingActor
      • pypushflow.tests.test_workflow1
        • pypushflow.tests.test_workflow1.TestWorkflow1
        • pypushflow.tests.test_workflow1.Workflow1
      • pypushflow.tests.test_workflow10
        • pypushflow.tests.test_workflow10.TestWorkflow10
        • pypushflow.tests.test_workflow10.Workflow10
      • pypushflow.tests.test_workflow2
        • pypushflow.tests.test_workflow2.TestWorkflow2
        • pypushflow.tests.test_workflow2.Workflow2
      • pypushflow.tests.test_workflow3
        • pypushflow.tests.test_workflow3.Submodel1
        • pypushflow.tests.test_workflow3.TestWorkflow3
        • pypushflow.tests.test_workflow3.Workflow3
      • pypushflow.tests.test_workflow4
        • pypushflow.tests.test_workflow4.Submodel4
        • pypushflow.tests.test_workflow4.TestWorkflow4
        • pypushflow.tests.test_workflow4.Workflow4
      • pypushflow.tests.test_workflow5
        • pypushflow.tests.test_workflow5.Submodel5
        • pypushflow.tests.test_workflow5.TestWorkflow5
        • pypushflow.tests.test_workflow5.Workflow5
      • pypushflow.tests.test_workflow6
        • pypushflow.tests.test_workflow6.Submodel6
        • pypushflow.tests.test_workflow6.TestWorkflow6
        • pypushflow.tests.test_workflow6.Workflow6
      • pypushflow.tests.workflowTestCase
        • pypushflow.tests.workflowTestCase.WorkflowTestCase
  • API documentation
  • pypushflow
  • pypushflow.tests
  • pypushflow.tests.tasks

pypushflow.tests.tasks#

Modules

pythonActor1

pythonActor2

pythonActorAdd

pythonActorAdd2

pythonActorAddAndCheck

pythonActorAddWithoutSleep

pythonActorCheck

pythonActorInterrupt

pythonActorSleep

pythonActorTest

pythonErrorHandlerTest

pythonLongExecutionTest

previous

pypushflow.tests.conftest.workflow_cleanup

next

pypushflow.tests.tasks.pythonActor1

This Page

  • Show Source

© Copyright 2021-2025, ESRF.

pypushflow 1.3.0