fix: jobs files disappear

jobs/jobs/db_service.py

@@ -211,7 +211,7 @@ def change_job(
     new_job_params: schemas.JobParamsToChange,
 ) -> None:
     """Changes any parameter of any job in db"""
-    new_job_params_dict = new_job_params.dict()
+    new_job_params_dict = new_job_params.dict(exclude_unset=True)
     for job_param_key in new_job_params_dict:
         if new_job_params_dict[job_param_key] is not None:
             setattr(job, job_param_key, new_job_params_dict[job_param_key])

jobs/tests/test_db.py

@@ -120,6 +120,8 @@ def create_mock_extraction_job_in_db(testing_session):
         all_files_data=all_files_data,
         status=schemas.Status.pending,
         categories=["label"],
+        pipeline_engine="airflow",
+        previous_jobs=[100],
     )
     return result
 
@@ -208,3 +210,50 @@ def test_create_ImportJob(testing_session):
     assert new_import_job
     assert new_import_job.name == "MockImportJob"
     assert new_import_job.type == schemas.JobType.ImportJob
+
+
+def test_change_job_single_field(testing_session):
+    job = create_mock_extraction_job_in_db(testing_session)
+
+    new_params = schemas.JobParamsToChange(status=schemas.Status.in_progress)
+    db_service.change_job(
+        db=testing_session, job=job, new_job_params=new_params
+    )
+
+    updated_job = db_service.get_job_in_db_by_id(testing_session, job.id)
+
+    assert updated_job.name == job.name
+    assert updated_job.status == schemas.Status.in_progress.value
+    assert updated_job.files == job.files
+    assert updated_job.datasets == job.datasets
+    assert updated_job.previous_jobs == job.previous_jobs
+    assert updated_job.creation_datetime == job.creation_datetime
+    assert updated_job.type == job.type
+    assert updated_job.mode == job.mode
+
+
+def test_change_job_many_fields(testing_session):
+    job = create_mock_extraction_job_in_db(testing_session)
+
+    new_params = schemas.JobParamsToChange(
+        status=schemas.Status.in_progress,
+        name="New",
+        files=[],
+        datasets=[1, 2, 3, 4],
+        previous_jobs=[],
+        type=schemas.JobType.ImportJob,
+        mode=schemas.JobMode.Automatic,
+    )
+    db_service.change_job(
+        db=testing_session, job=job, new_job_params=new_params
+    )
+
+    updated_job = db_service.get_job_in_db_by_id(testing_session, job.id)
+
+    assert updated_job.name == new_params.name
+    assert updated_job.status == new_params.status
+    assert updated_job.files == new_params.files
+    assert updated_job.datasets == new_params.datasets
+    assert updated_job.previous_jobs == new_params.previous_jobs
+    assert updated_job.type == new_params.type
+    assert updated_job.mode == new_params.mode