Activities

An activity is a unit of work that performs a specific task or operation (e.g. making an API request, processing data, sending an email) and can be executed by a workflow.

You may use the make:activity artisan command to create a new activity:

php artisan make:activity MyActivity

It is defined by extending the Activity class and implementing the handle() method.

use Workflow\V2\Activity;

class MyActivity extends Activity
{
    public function handle()
    {
        // Perform some work...
        return $result;
    }
}

Per-Call Activity Options

By default, activity routing and retry policy come from the activity class properties ($connection, $queue, $tries, backoff()). When you need to override those on a per-call basis, pass an ActivityOptions instance as the first argument after the activity class:

use function Workflow\V2\activity;
use Workflow\V2\Support\ActivityOptions;

$result = activity(
    MyActivity::class,
    new ActivityOptions(
        connection: 'sqs',
        queue: 'high-priority',
        maxAttempts: 5,
        backoff: [1, 5, 15],
    ),
    'Taylor',
);

The same pattern works with closures inside all() for parallel activity calls:

use function Workflow\V2\all;
use Workflow\V2\Support\ActivityOptions;

$results = all([
    fn () => activity(
        MyActivity::class,
        new ActivityOptions(queue: 'batch'),
        $name,
    ),
]);

Available options

Option	Type	Description
connection	string	Queue connection override
queue	string	Queue name override
maxAttempts	int	Override the activity class $tries
backoff	int\|list<int>	Override the activity class backoff()
startToCloseTimeout	int	Seconds from activity start to required completion (per attempt)
scheduleToStartTimeout	int	Seconds from scheduling to first claim
scheduleToCloseTimeout	int	Total wall-clock seconds from scheduling to completion across all retries
heartbeatTimeout	int	Seconds between heartbeats before the activity is considered unresponsive

Resolution order

Per-call options take highest priority, then activity class properties, then the parent workflow run's routing:

1. ActivityOptions values (if provided)
2. Activity class $connection, $queue, $tries, backoff() properties
3. Parent workflow run's connection and queue
4. Laravel queue config defaults