feat: new spike on a persisted pipeline pattern

enterprise_access/apps/pipeline/admin.py

@@ -0,0 +1,58 @@
+from django.contrib import admin
+
+from .models import (
+    PizzaPipeline,
+    StretchDoughStep,
+    AddToppingsStep,
+    BakePizzaStep,
+)
+
+
+@admin.register(PizzaPipeline)
+class PizzaPipelineAdmin(admin.ModelAdmin):
+    list_display = [
+        'uuid',
+        'succeeded_at',
+        'failed_at',
+        'input_data',
+    ]
+
+    list_filter = [
+        ('succeeded_at', admin.EmptyFieldListFilter),
+        ('failed_at', admin.EmptyFieldListFilter),
+    ]
+
+    readonly_fields = [
+        'output_data',
+        'succeeded_at',
+        'failed_at',
+    ]
+
+    ordering = ['-succeeded_at']
+
+
+@admin.register(StretchDoughStep)
+class StretchDoughStepAdmin(admin.ModelAdmin):
+    readonly_fields = [
+        'output_data',
+        'succeeded_at',
+        'failed_at',
+    ]
+
+
+@admin.register(AddToppingsStep)
+class AddToppingsStepAdmin(admin.ModelAdmin):
+    readonly_fields = [
+        'output_data',
+        'succeeded_at',
+        'failed_at',
+    ]
+
+
+@admin.register(BakePizzaStep)
+class BakePizzaStepAdmin(admin.ModelAdmin):
+    readonly_fields = [
+        'output_data',
+        'succeeded_at',
+        'failed_at',
+    ]

enterprise_access/apps/pipeline/apps.py

@@ -0,0 +1,6 @@
+from django.apps import AppConfig
+
+
+class PipelineConfig(AppConfig):
+    default_auto_field = 'django.db.models.BigAutoField'
+    name = 'enterprise_access.apps.pipeline'

enterprise_access/apps/pipeline/migrations/0001_initial.py

@@ -0,0 +1,96 @@
+# Generated by Django 4.2.17 on 2025-01-24 14:24
+
+from django.db import migrations, models
+import django.db.models.deletion
+import django.utils.timezone
+import jsonfield.fields
+import model_utils.fields
+import uuid
+
+
+class Migration(migrations.Migration):
+
+    initial = True
+
+    dependencies = [
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='AddToppingsStep',
+            fields=[
+                ('created', model_utils.fields.AutoCreatedField(default=django.utils.timezone.now, editable=False, verbose_name='created')),
+                ('modified', model_utils.fields.AutoLastModifiedField(default=django.utils.timezone.now, editable=False, verbose_name='modified')),
+                ('is_removed', models.BooleanField(default=False)),
+                ('uuid', models.UUIDField(default=uuid.uuid4, editable=False, primary_key=True, serialize=False, unique=True)),
+                ('input_data', jsonfield.fields.JSONField(blank=True)),
+                ('output_data', jsonfield.fields.JSONField(blank=True, editable=False, null=True)),
+                ('succeeded_at', models.DateTimeField(blank=True, null=True)),
+                ('failed_at', models.DateTimeField(blank=True, null=True)),
+            ],
+            options={
+                'abstract': False,
+            },
+        ),
+        migrations.CreateModel(
+            name='PizzaPipeline',
+            fields=[
+                ('created', model_utils.fields.AutoCreatedField(default=django.utils.timezone.now, editable=False, verbose_name='created')),
+                ('modified', model_utils.fields.AutoLastModifiedField(default=django.utils.timezone.now, editable=False, verbose_name='modified')),
+                ('is_removed', models.BooleanField(default=False)),
+                ('uuid', models.UUIDField(default=uuid.uuid4, editable=False, primary_key=True, serialize=False, unique=True)),
+                ('input_data', jsonfield.fields.JSONField(blank=True)),
+                ('output_data', jsonfield.fields.JSONField(blank=True, editable=False, null=True)),
+                ('succeeded_at', models.DateTimeField(blank=True, null=True)),
+                ('failed_at', models.DateTimeField(blank=True, null=True)),
+            ],
+            options={
+                'abstract': False,
+            },
+        ),
+        migrations.CreateModel(
+            name='StretchDoughStep',
+            fields=[
+                ('created', model_utils.fields.AutoCreatedField(default=django.utils.timezone.now, editable=False, verbose_name='created')),
+                ('modified', model_utils.fields.AutoLastModifiedField(default=django.utils.timezone.now, editable=False, verbose_name='modified')),
+                ('is_removed', models.BooleanField(default=False)),
+                ('uuid', models.UUIDField(default=uuid.uuid4, editable=False, primary_key=True, serialize=False, unique=True)),
+                ('input_data', jsonfield.fields.JSONField(blank=True)),
+                ('output_data', jsonfield.fields.JSONField(blank=True, editable=False, null=True)),
+                ('succeeded_at', models.DateTimeField(blank=True, null=True)),
+                ('failed_at', models.DateTimeField(blank=True, null=True)),
+                ('pipeline_record', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='pipeline.pizzapipeline')),
+            ],
+            options={
+                'abstract': False,
+            },
+        ),
+        migrations.CreateModel(
+            name='BakePizzaStep',
+            fields=[
+                ('created', model_utils.fields.AutoCreatedField(default=django.utils.timezone.now, editable=False, verbose_name='created')),
+                ('modified', model_utils.fields.AutoLastModifiedField(default=django.utils.timezone.now, editable=False, verbose_name='modified')),
+                ('is_removed', models.BooleanField(default=False)),
+                ('uuid', models.UUIDField(default=uuid.uuid4, editable=False, primary_key=True, serialize=False, unique=True)),
+                ('input_data', jsonfield.fields.JSONField(blank=True)),
+                ('output_data', jsonfield.fields.JSONField(blank=True, editable=False, null=True)),
+                ('succeeded_at', models.DateTimeField(blank=True, null=True)),
+                ('failed_at', models.DateTimeField(blank=True, null=True)),
+                ('pipeline_record', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='pipeline.pizzapipeline')),
+                ('preceding_step', models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='pipeline.addtoppingsstep')),
+            ],
+            options={
+                'abstract': False,
+            },
+        ),
+        migrations.AddField(
+            model_name='addtoppingsstep',
+            name='pipeline_record',
+            field=models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='pipeline.pizzapipeline'),
+        ),
+        migrations.AddField(
+            model_name='addtoppingsstep',
+            name='preceding_step',
+            field=models.ForeignKey(on_delete=django.db.models.deletion.CASCADE, to='pipeline.stretchdoughstep'),
+        ),
+    ]

enterprise_access/apps/pipeline/migrations/0002_alter_addtoppingsstep_output_data_and_more.py

@@ -0,0 +1,34 @@
+# Generated by Django 4.2.17 on 2025-01-27 15:20
+
+from django.db import migrations
+import jsonfield.fields
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('pipeline', '0001_initial'),
+    ]
+
+    operations = [
+        migrations.AlterField(
+            model_name='addtoppingsstep',
+            name='output_data',
+            field=jsonfield.fields.JSONField(blank=True, null=True),
+        ),
+        migrations.AlterField(
+            model_name='bakepizzastep',
+            name='output_data',
+            field=jsonfield.fields.JSONField(blank=True, null=True),
+        ),
+        migrations.AlterField(
+            model_name='pizzapipeline',
+            name='output_data',
+            field=jsonfield.fields.JSONField(blank=True, null=True),
+        ),
+        migrations.AlterField(
+            model_name='stretchdoughstep',
+            name='output_data',
+            field=jsonfield.fields.JSONField(blank=True, null=True),
+        ),
+    ]