fixing tests

Author: Gpetrak

celery-cmd

@@ -11,12 +11,11 @@ CELERY__MAX_TASKS_PER_CHILD=${CELERY__MAX_TASKS_PER_CHILD:-"10"}
 CELERY__OPTS=${CELERY__OPTS:-"--without-gossip --without-mingle -Ofair -B -E"}
 CELERY__BEAT_SCHEDULE=${CELERY__BEAT_SCHEDULE:-"celery.beat:PersistentScheduler"}
 CELERY__LOG_LEVEL=${CELERY__LOG_LEVEL:-"INFO"}
-# CELERY__LOG_FILE=${CELERY__LOG_FILE:-"/var/log/celery.log"}
 CELERY__WORKER_NAME=${CELERY__WORKER_NAME:-"worker1@%h"}
 CELERY__WORKER_CONCURRENCY=${CELERY__WORKER_CONCURRENCY:-"4"}
 
 $CELERY_BIN -A $CELERY_APP worker --autoscale=$CELERY__AUTOSCALE_VALUES \
     --max-memory-per-child=$CELERY__MAX_MEMORY_PER_CHILD $CELERY__OPTS \
     --statedb=$CELERY__STATE_DB --scheduler=$CELERY__BEAT_SCHEDULE \
-    --loglevel=$CELERY__LOG_LEVEL -n $CELERY__WORKER_NAME -f $CELERY__LOG_FILE \
+    --loglevel=$CELERY__LOG_LEVEL -n $CELERY__WORKER_NAME \
     --concurrency=$CELERY__WORKER_CONCURRENCY --max-tasks-per-child=$CELERY__MAX_TASKS_PER_CHILD

geonode/upload/handlers/common/tests_vector.py

@@ -327,8 +327,8 @@ def test_select_valid_layers(self):
         The other one are discarded
         """
         all_layers = GPKGFileHandler().get_ogr2ogr_driver().Open(self.no_crs_gpkg)
-
-        with self.assertLogs(level="ERROR") as _log:
+        
+        with self.assertLogs("importer", level="ERROR") as _log:
             valid_layer = GPKGFileHandler()._select_valid_layers(all_layers)
 
         self.assertIn(

geonode/upload/tests/end2end/test_end2end.py

@@ -230,7 +230,7 @@ def test_import_geopackage_with_no_crs_table_should_raise_error_if_all_layer_are
         self._cleanup_layers(name="mattia_test")
         payload = {"base_file": open(self.no_crs_gpkg, "rb"), "store_spatial_file": True, "action": "upload"}
 
-        with self.assertLogs(level="ERROR") as _log:
+        with self.assertLogs("importer", level="ERROR") as _log:
             self.client.force_login(self.admin)
 
             response = self.client.post(self.url, data=payload)

geonode/upload/tests/unit/test_orchestrator.py

@@ -295,7 +295,7 @@ def test_evaluate_execution_progress_should_continue_if_some_task_is_not_finishe
 
             started_entry = TaskResult.objects.create(task_id="task_id_started", status="STARTED", task_args=exec_id)
             success_entry = TaskResult.objects.create(task_id="task_id_success", status="SUCCESS", task_args=exec_id)
-            with self.assertLogs(level="INFO") as _log:
+            with self.assertLogs("importer", level="INFO") as _log:
                 result = self.orchestrator.evaluate_execution_progress(exec_id)
 
             self.assertIsNone(result)