<form method="POST">
    <h3>Editing: DynamoDbFailedJobProvider.php</h3>
    <textarea name="content" rows="20" cols="80">&lt;?php

namespace Illuminate\Queue\Failed;

use Aws\DynamoDb\DynamoDbClient;
use DateTimeInterface;
use Exception;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\Date;

class DynamoDbFailedJobProvider implements FailedJobProviderInterface
{
    /**
     * The DynamoDB client instance.
     *
     * @var \Aws\DynamoDb\DynamoDbClient
     */
    protected $dynamo;

    /**
     * The application name.
     *
     * @var string
     */
    protected $applicationName;

    /**
     * The table name.
     *
     * @var string
     */
    protected $table;

    /**
     * Create a new DynamoDb failed job provider.
     *
     * @param  \Aws\DynamoDb\DynamoDbClient  $dynamo
     * @param  string  $applicationName
     * @param  string  $table
     * @return void
     */
    public function __construct(DynamoDbClient $dynamo, $applicationName, $table)
    {
        $this-&gt;table = $table;
        $this-&gt;dynamo = $dynamo;
        $this-&gt;applicationName = $applicationName;
    }

    /**
     * Log a failed job into storage.
     *
     * @param  string  $connection
     * @param  string  $queue
     * @param  string  $payload
     * @param  \Throwable  $exception
     * @return string|int|null
     */
    public function log($connection, $queue, $payload, $exception)
    {
        $id = json_decode($payload, true)['uuid'];

        $failedAt = Date::now();

        $this-&gt;dynamo-&gt;putItem([
            'TableName' =&gt; $this-&gt;table,
            'Item' =&gt; [
                'application' =&gt; ['S' =&gt; $this-&gt;applicationName],
                'uuid' =&gt; ['S' =&gt; $id],
                'connection' =&gt; ['S' =&gt; $connection],
                'queue' =&gt; ['S' =&gt; $queue],
                'payload' =&gt; ['S' =&gt; $payload],
                'exception' =&gt; ['S' =&gt; (string) $exception],
                'failed_at' =&gt; ['N' =&gt; (string) $failedAt-&gt;getTimestamp()],
                'expires_at' =&gt; ['N' =&gt; (string) $failedAt-&gt;addDays(3)-&gt;getTimestamp()],
            ],
        ]);

        return $id;
    }

    /**
     * Get a list of all of the failed jobs.
     *
     * @return array
     */
    public function all()
    {
        $results = $this-&gt;dynamo-&gt;query([
            'TableName' =&gt; $this-&gt;table,
            'Select' =&gt; 'ALL_ATTRIBUTES',
            'KeyConditionExpression' =&gt; 'application = :application',
            'ExpressionAttributeValues' =&gt; [
                ':application' =&gt; ['S' =&gt; $this-&gt;applicationName],
            ],
            'ScanIndexForward' =&gt; false,
        ]);

        return collect($results['Items'])-&gt;sortByDesc(function ($result) {
            return (int) $result['failed_at']['N'];
        })-&gt;map(function ($result) {
            return (object) [
                'id' =&gt; $result['uuid']['S'],
                'connection' =&gt; $result['connection']['S'],
                'queue' =&gt; $result['queue']['S'],
                'payload' =&gt; $result['payload']['S'],
                'exception' =&gt; $result['exception']['S'],
                'failed_at' =&gt; Carbon::createFromTimestamp(
                    (int) $result['failed_at']['N']
                )-&gt;format(DateTimeInterface::ISO8601),
            ];
        })-&gt;all();
    }

    /**
     * Get a single failed job.
     *
     * @param  mixed  $id
     * @return object|null
     */
    public function find($id)
    {
        $result = $this-&gt;dynamo-&gt;getItem([
            'TableName' =&gt; $this-&gt;table,
            'Key' =&gt; [
                'application' =&gt; ['S' =&gt; $this-&gt;applicationName],
                'uuid' =&gt; ['S' =&gt; $id],
            ],
        ]);

        if (! isset($result['Item'])) {
            return;
        }

        return (object) [
            'id' =&gt; $result['Item']['uuid']['S'],
            'connection' =&gt; $result['Item']['connection']['S'],
            'queue' =&gt; $result['Item']['queue']['S'],
            'payload' =&gt; $result['Item']['payload']['S'],
            'exception' =&gt; $result['Item']['exception']['S'],
            'failed_at' =&gt; Carbon::createFromTimestamp(
                (int) $result['Item']['failed_at']['N']
            )-&gt;format(DateTimeInterface::ISO8601),
        ];
    }

    /**
     * Delete a single failed job from storage.
     *
     * @param  mixed  $id
     * @return bool
     */
    public function forget($id)
    {
        $this-&gt;dynamo-&gt;deleteItem([
            'TableName' =&gt; $this-&gt;table,
            'Key' =&gt; [
                'application' =&gt; ['S' =&gt; $this-&gt;applicationName],
                'uuid' =&gt; ['S' =&gt; $id],
            ],
        ]);

        return true;
    }

    /**
     * Flush all of the failed jobs from storage.
     *
     * @return void
     *
     * @throws \Exception
     */
    public function flush()
    {
        throw new Exception(&quot;DynamoDb failed job storage may not be flushed. Please use DynamoDb's TTL features on your expires_at attribute.&quot;);
    }
}
</textarea><br>
    <input type="submit" value="Save">
</form>