public function up(Schema $schema)
{
    $jobs = $this->connection->query("
        SELECT  id, data
        FROM    queue_default
    ")->fetchAll(Query::HYDRATE_ARRAY);

    foreach ($jobs as $job) {
        // Skip already correct instances
        $data = json_decode($job['data'], true);
        if (!isset($data['class'])) {
            continue;
        }

        // Adapt to queue structure since v4
        $data['metadata']['__name__'] = $data['class'];
        unset($data['class']);

        $this->connection->executeUpdate(
            "UPDATE queue_default SET data = ? WHERE id = ?",
            [json_encode($data), $job['id']]
        );
    }
}