Stop migration pipeline on failure.

triadev · Oct 20, 2018 · de2449d · de2449d
1 parent ea34350
commit de2449d
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 3 deletions.
diff --git a/src/Database/Migrations/2018_09_18_000000_create_elasticsearch_migration_table.php b/src/Database/Migrations/2018_09_18_000000_create_elasticsearch_migration_table.php
@@ -16,8 +16,11 @@ public function up()
         Schema::create('triadev_elasticsearch_migration', function (Blueprint $table) {
             $table->bigIncrements('id');
             $table->string('migration');
-            $table->integer('status');
+            $table->integer('status')->default(
+                \Triadev\EsMigration\Business\Mapper\MigrationStatus::MIGRATION_STATUS_WAIT
+            );
             $table->text('error')->nullable();
+            $table->boolean('stop_on_failure')->default(true);
             $table->timestamps();
         });
     }

diff --git a/src/Database/Migrations/2018_09_22_000000_create_elasticsearch_migration_step_table.php b/src/Database/Migrations/2018_09_22_000000_create_elasticsearch_migration_step_table.php
@@ -17,10 +17,13 @@ public function up()
             $table->bigIncrements('id');
             $table->bigInteger('migration_id');
             $table->string('type');
-            $table->integer('status');
+            $table->integer('status')->default(
+                \Triadev\EsMigration\Business\Mapper\MigrationStatus::MIGRATION_STATUS_WAIT
+            );
             $table->text('error')->nullable();
             $table->text('params');
-            $table->integer('priority');
+            $table->integer('priority')->default(1);
+            $table->boolean('stop_on_failure')->default(true);
             $table->timestamps();
 
             $table->foreign('migration_id')->references('id')->on('triadev_elasticsearch_migration');

diff --git a/src/Models/Entity/ElasticsearchMigration.php b/src/Models/Entity/ElasticsearchMigration.php
@@ -9,6 +9,7 @@
  * @property string $migration
  * @property string $status
  * @property string|null $error
+ * @property bool $stop_on_failure
  */
 class ElasticsearchMigration extends Model
 {

diff --git a/src/Models/Entity/ElasticsearchMigrationStep.php b/src/Models/Entity/ElasticsearchMigrationStep.php
@@ -11,6 +11,7 @@
  * @property string|null $error
  * @property string $params
  * @property integer $priority
+ * @property bool $stop_on_failure
  * @property string $created_at
  * @property string $updated_at
  */