Prove workflow migration install paths

Author: durable-workflow-ops

src/migrations/2026_04_16_000158_repair_memo_on_workflow_run_summaries_table.php

@@ -0,0 +1,30 @@
+<?php
+
+declare(strict_types=1);
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class() extends Migration {
+    public function up(): void
+    {
+        if (
+            ! Schema::hasTable('workflow_run_summaries')
+            || Schema::hasColumn('workflow_run_summaries', 'memo')
+        ) {
+            return;
+        }
+
+        Schema::table('workflow_run_summaries', static function (Blueprint $table): void {
+            $table->json('memo')
+                ->nullable();
+        });
+    }
+
+    public function down(): void
+    {
+        // Intentionally no-op: fresh 2.0 installs create this column in the
+        // base workflow_run_summaries migration, and rollback must not remove it.
+    }
+};

tests/Feature/MigrationTest.php

@@ -110,6 +110,31 @@ public function testScheduleHistoryMigrationCanResumeAfterPartialMysqlIndexFailu
         $this->assertTrue(Schema::hasIndex('workflow_schedule_history_events', ['event_type', 'recorded_at']));
     }
 
+    public function testRunSummaryMemoRepairMigrationAddsMissingMemoColumn(): void
+    {
+        $path = __DIR__ . '/../../src/migrations/2026_04_16_000158_repair_memo_on_workflow_run_summaries_table.php';
+
+        Schema::create('workflow_run_summaries', static function (Blueprint $table): void {
+            $table->string('id', 26)
+                ->primary();
+            $table->json('visibility_labels')
+                ->nullable();
+            $table->timestamps(6);
+        });
+
+        $this->assertTrue(Schema::hasTable('workflow_run_summaries'));
+        $this->assertFalse(Schema::hasColumn('workflow_run_summaries', 'memo'));
+
+        $migration = include $path;
+        $migration->up();
+
+        $this->assertTrue(Schema::hasColumn('workflow_run_summaries', 'memo'));
+
+        $migration->up();
+
+        $this->assertTrue(Schema::hasColumn('workflow_run_summaries', 'memo'));
+    }
+
     public function testItPreservesV1WorkflowDataAfterV2Migration()
     {
         // Set up v1 schema and data

tests/Unit/Providers/WorkflowServiceProviderTest.php

@@ -109,9 +109,44 @@ public function testProviderLoadsPackageMigrationsForFreshApps(): void
         $this->assertTrue(Schema::hasTable('workflow_instances'));
         $this->assertTrue(Schema::hasTable('workflow_runs'));
         $this->assertTrue(Schema::hasTable('workflow_run_summaries'));
+        $this->assertTrue(Schema::hasColumn('workflow_run_summaries', 'memo'));
         $this->assertTrue(Schema::hasTable('workflow_commands'));
     }
 
+    public function testPublishedMigrationsCanRunAsInstallSource(): void
+    {
+        $this->deletePublishedWorkflowMigrations();
+
+        try {
+            Artisan::call('vendor:publish', [
+                '--tag' => 'migrations',
+                '--force' => true,
+            ]);
+
+            $migrationFiles = glob(database_path('migrations/*.php')) ?: [];
+            $this->assertNotEmpty($migrationFiles, 'Migrations should be published');
+
+            Schema::dropAllTables();
+
+            $this->artisan('migrate:install')
+                ->run();
+
+            $this->artisan('migrate', [
+                '--path' => database_path('migrations'),
+                '--realpath' => true,
+            ])->run();
+
+            $this->assertTrue(Schema::hasTable('workflow_instances'));
+            $this->assertTrue(Schema::hasTable('workflow_runs'));
+            $this->assertTrue(Schema::hasTable('workflow_run_summaries'));
+            $this->assertTrue(Schema::hasColumn('workflow_run_summaries', 'memo'));
+            $this->assertTrue(Schema::hasTable('workflow_schedules'));
+            $this->assertTrue(Schema::hasTable('workflow_schedule_history_events'));
+        } finally {
+            $this->deletePublishedWorkflowMigrations();
+        }
+    }
+
     public function testCommandsAreRegistered(): void
     {
         $registeredCommands = array_keys(Artisan::all());
@@ -218,8 +253,17 @@ public function testLoopingEventSkipsWatchdogsBeforeWorkflowTablesExist(): void
         Cache::forget('workflow:watchdog:looping');
         Cache::forget(TaskWatchdog::LOOP_THROTTLE_KEY);
 
-        Schema::dropIfExists('workflows');
-        Schema::dropIfExists('workflow_worker_compatibility_heartbeats');
+        foreach ([
+            'workflow_relationships',
+            'workflow_exceptions',
+            'workflow_timers',
+            'workflow_signals',
+            'workflow_logs',
+            'workflows',
+            'workflow_worker_compatibility_heartbeats',
+        ] as $table) {
+            Schema::dropIfExists($table);
+        }
 
         Event::dispatch(new Looping('redis', 'default'));
 
@@ -291,4 +335,16 @@ public function testLoopingEventRepairsOverdueV2Task(): void
         $this->assertSame(1, $task->repair_count);
         $this->assertNotNull($task->last_dispatched_at);
     }
+
+    private function deletePublishedWorkflowMigrations(): void
+    {
+        $sourceFiles = glob(dirname(__DIR__, 3) . '/src/migrations/*.php') ?: [];
+        $publishedNames = array_fill_keys(array_map('basename', $sourceFiles), true);
+
+        foreach (glob(database_path('migrations/*.php')) ?: [] as $file) {
+            if (isset($publishedNames[basename($file)])) {
+                @unlink($file);
+            }
+        }
+    }
 }