/\ ATFGraph /docs
README Downloads
Examples / ATFGraph
Framework reference

This article is retained from the existing framework docs. Self-hosting commands and server-admin access differ from the managed CLI workflow. Start with Get started for the installed product.

Nested concurrency

Directory examples/python/nested_concurrency

Agent node label fanout, version 1.0.0.

Capabilities

CapabilityKindSignatureModuleSummary
fan_outtraversal(count: int = 6, batch: int = 3) -> dictexamples/python/nested_concurrency/agent.pySquare ``count`` numbers in batches of ``batch``, then run one retrying step.
flaky_stepskill(succeed_on_attempt: int = 2) -> dictexamples/python/nested_concurrency/agent.pyFails with a retryable error until the server has scheduled ``succeed_on_attempt`` attempts.
long_parenttraversal(seconds: float = 30) -> dictexamples/python/nested_concurrency/agent.pyA parent whose child sleeps; cancel the parent to see propagation.
slow_stepskill(seconds: float) -> dictexamples/python/nested_concurrency/agent.pySleeps in small slices so a server cancel interrupts it promptly.
squareskill(n: int) -> dictexamples/python/nested_concurrency/agent.py

Non-default capability options: flaky_step: max_attempts=3; long_parent: timeout_seconds=600; slow_step: timeout_seconds=600

Commands

Taken from this example's own README and module docstrings.

python -m atfgraph.worker --module examples.python.nested_concurrency.agent:app --capacity 1
python -m examples.python.nested_concurrency.call

Files

  • examples/python/nested_concurrency/__init__.py
  • examples/python/nested_concurrency/agent.py
  • examples/python/nested_concurrency/agentnode.yaml
  • examples/python/nested_concurrency/call.py
ATFGraph documentationHosted workflow · Framework reference