Remove the transitional Job.compute_profile string field (step 1)

Job.compute_profile (string) was a stopgap superseded by compute_profile_fk
(FK -> ComputeProfile), the source of truth for the profile a job ran on. The
two were written together and always agreed at creation; this retires the string.

Step 1 of a two-step removal (mirrors Program.default_compute_profile, #2420 ->
#2421): repoint every reader to the FK via a new null-safe Job.compute_profile_id
property, then remove the field from Django's model STATE only. The DB column is
left in place so the previous release stays deployable; the real DROP COLUMN
ships in a later PR once no field-declaring release can deploy.

- Readers repointed to compute_profile_id: fleet name + resource limits
  (fleets_runner), billing classical metric type (kafka_event_streams_client),
  admin job timeline (+ select_related to avoid an N+1).
- Writers: run path and filler-jobs path no longer write the string (both
  already set compute_profile_fk).
- API: compute_profile dropped from job serializers; compute_profile_fk (already
  present) carries the profile. Client Job loses its compute_profile attribute.
- Admin: field removed from the JobAdmin Fleets fieldset.
- Migration 0064: state-only RemoveField wrapped in SeparateDatabaseAndState.

Out of scope: the DROP COLUMN (step 2) and the deprecated compute_profile run
input kwarg (use function_size).

Author: ElePT

client/qiskit_serverless/core/clients/serverless_client.py

@@ -236,7 +236,6 @@ def jobs(self, function: Optional[QiskitFunction] = None, **kwargs) -> List[Job]
                 job.get("id"),
                 job_service=self,
                 raw_data=job,
-                compute_profile=job.get("compute_profile"),
             )
             for job in response_data.get("results", [])
         ]
@@ -291,7 +290,6 @@ def provider_jobs(self, function: Optional[QiskitFunction], **kwargs) -> List[Jo
                 job.get("id"),
                 job_service=self,
                 raw_data=job,
-                compute_profile=job.get("compute_profile"),
             )
             for job in response_data.get("results", [])
         ]
@@ -314,7 +312,6 @@ def job(self, job_id: str) -> Optional[Job]:
             job = Job(
                 job_id=job_id,
                 job_service=self,
-                compute_profile=response_data.get("compute_profile"),
             )
 
         return job
@@ -376,7 +373,6 @@ def run(
         return Job(
             job_id,
             job_service=self,
-            compute_profile=response_data.get("compute_profile"),
         )
 
     def get_job_data(self, job_id: str) -> Optional[dict]:

client/qiskit_serverless/core/job.py

@@ -168,7 +168,6 @@ def __init__(
         job_id: str,
         job_service: JobService,
         raw_data: Optional[Dict[str, Any]] = None,
-        compute_profile: Optional[str] = None,
     ):
         """Job class for async script execution.
 
@@ -178,7 +177,6 @@ def __init__(
         """
         self.job_id = job_id
         self._job_service = job_service
-        self.compute_profile = compute_profile
         self.raw_data = raw_data or {}
 
     @property

client/tests/core/test_serverless_client_jobs.py

@@ -1140,16 +1140,13 @@ def test_run_with_compute_profile(self, mock_client):
                 json=mock_response,
             )
 
-            job = mock_client.run(program="test-program", compute_profile="gx3d-24x120x1a100p")
+            mock_client.run(program="test-program", compute_profile="gx3d-24x120x1a100p")
 
-            # Verify client sent compute_profile to API
+            # Verify client sent the (deprecated) compute_profile input to the API
             request_data = json.loads(mock_request.last_request.text)
             assert "compute_profile" in request_data
             assert request_data["compute_profile"] == "gx3d-24x120x1a100p"
 
-            # Verify Job.compute_profile property works
-            assert job.compute_profile == "gx3d-24x120x1a100p"
-
     def test_run_without_compute_profile(self, mock_client):
         """Test run() without compute_profile - backend applies default."""
         # Mock response includes default compute_profile applied by backend
@@ -1169,11 +1166,8 @@ def test_run_without_compute_profile(self, mock_client):
                 json=mock_response,
             )
 
-            job = mock_client.run(program="test-program")
+            mock_client.run(program="test-program")
 
             # Verify client sent compute_profile as None (backend will apply default)
             request_data = json.loads(mock_request.last_request.text)
             assert request_data["compute_profile"] is None
-
-            # Verify backend applied the default
-            assert job.compute_profile == "cx3d-4x16"

gateway/api/admin.py

@@ -505,7 +505,6 @@ class JobAdmin(admin.ModelAdmin):
                 "fields": [
                     "filler",
                     "fleet_id",
-                    "compute_profile",
                     "compute_profile_fk",
                     "size_source",
                     "function_size",
@@ -575,7 +574,11 @@ def job_timeline_view(self, request):
                 continue
         # one single query: the rendering iterates the jobs again, and re-running the queryset
         # could come back empty (deleted in between) and break the rendering half way through
-        jobs = list(Job.objects.filter(id__in=id_list).select_related("author").prefetch_related("job_events"))
+        jobs = list(
+            Job.objects.filter(id__in=id_list)
+            .select_related("author", "compute_profile_fk")
+            .prefetch_related("job_events")
+        )
         if not id_list or not jobs:
             messages.error(request, "No jobs selected for the timeline.")
             return redirect(reverse("admin:api_job_changelist"))
@@ -725,7 +728,7 @@ def index(self, request, extra_context=None):
         if timeline_context is None:
             recent_jobs = list(
                 Job.objects.filter(runner=Program.FLEETS)
-                .select_related("author")
+                .select_related("author", "compute_profile_fk")
                 .prefetch_related("job_events")
                 .order_by("-created")[:20]
             )

gateway/api/domain/job_timeline.py

@@ -67,7 +67,7 @@ def _jobs_from_queryset(jobs_qs):
                 "status": job.status,
                 "runner": job.runner,
                 "filler": job.filler,
-                "profile": job.compute_profile or "-",
+                "profile": job.compute_profile_id or "-",
                 "created": job.created,
                 "updated": job.updated,
                 "running_started_at": job.running_started_at,

gateway/api/migrations/0064_remove_job_compute_profile_state.py

@@ -0,0 +1,29 @@
+from django.db import migrations
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ("api", "0063_merge_20260902_1720"),
+    ]
+
+    operations = [
+        # Step 1 of a two-step removal of Job.compute_profile (the transitional
+        # string). compute_profile_fk (FK -> ComputeProfile) is the source of
+        # truth and every reader now goes through Job.compute_profile_id, which
+        # reads the FK. Here the field is dropped from Django's state ONLY; the
+        # api_job.compute_profile column is left in place so the previous release
+        # -- whose Job model still declares the field and lists it in every SELECT
+        # -- stays deployable. The real DROP COLUMN happens in a later release,
+        # once no release that declares the field can still be deployed (mirrors
+        # the Program.default_compute_profile removal, migrations 0057 -> 0058).
+        migrations.SeparateDatabaseAndState(
+            state_operations=[
+                migrations.RemoveField(
+                    model_name="job",
+                    name="compute_profile",
+                ),
+            ],
+            database_operations=[],
+        ),
+    ]

gateway/api/use_cases/programs/run.py

@@ -72,12 +72,11 @@ def _get_runner_config(
 ) -> RunnerConfig:
     """Resolve the compute profile and sizing provenance for a run.
 
-    ``compute_profile`` (string) is transitional and will be removed; the FK
-    ``compute_profile_fk`` is the source of truth going forward. They always agree
-    at creation. A Fleets job always resolves to a profile string; if no
-    ``ComputeProfile`` row is registered for it, that is a deployment
-    misconfiguration and we reject the job rather than store a null FK. Ray leaves
-    ``compute_profile`` None (profiles are a Fleets concept), so the FK stays null.
+    ``compute_profile_fk`` is the source of truth for the profile a job runs at
+    and is what gets stored on the job. A Fleets job always resolves to a profile;
+    if no ``ComputeProfile`` row is registered for it, that is a deployment
+    misconfiguration and we reject the job rather than store a null FK. Ray is not
+    profiled (profiles are a Fleets concept), so its FK stays null.
 
     Because the size determines the compute profile (and not the reverse -- two
     sizes can map to one profile), the returned :class:`RunnerConfig` also records
@@ -237,7 +236,6 @@ def execute(  # pylint: disable=too-many-locals, too-many-branches
             author=user,
             gpu=runner_config.gpu,
             runner=function.runner,
-            compute_profile=runner_config.compute_profile,
             compute_profile_fk=runner_config.compute_profile_fk,
             size_source=runner_config.size_source,
             function_size=runner_config.function_size,

gateway/api/v1/views/jobs/list.py

@@ -86,7 +86,7 @@ class JobSerializerWithoutResult(serializers.ModelSerializer):
 
     class Meta:
         model = Job
-        fields = ["id", "status", "program", "created", "sub_status", "compute_profile", "compute_profile_fk"]
+        fields = ["id", "status", "program", "created", "sub_status", "compute_profile_fk"]
         ref_name = "JobsListWithoutResultInputSerializer"
 
 

gateway/api/v1/views/jobs/retrieve.py

@@ -82,7 +82,6 @@ class Meta:
             "created",
             "sub_status",
             "fleet_id",
-            "compute_profile",
             "compute_profile_fk",
             "business_model",
         ]
@@ -113,7 +112,6 @@ class Meta:
             "created",
             "sub_status",
             "fleet_id",
-            "compute_profile",
             "compute_profile_fk",
             "business_model",
         ]

gateway/api/v1/views/programs/get_jobs.py

@@ -50,7 +50,7 @@ class OutputSerializer(serializers.ModelSerializer):
 
     class Meta:
         model = Job
-        fields = ["id", "result", "status", "program", "created", "sub_status", "fleet_id", "compute_profile"]
+        fields = ["id", "result", "status", "program", "created", "sub_status", "fleet_id"]
         ref_name = "ProgramsGetJobsOutput"
 
 
@@ -65,7 +65,7 @@ class OutputSerializerWithoutResult(serializers.ModelSerializer):
 
     class Meta:
         model = Job
-        fields = ["id", "status", "program", "created", "sub_status", "fleet_id", "compute_profile"]
+        fields = ["id", "status", "program", "created", "sub_status", "fleet_id"]
         ref_name = "ProgramsGetJobsOutputWithoutResult"