fix(datashare-tasks): fix TaskManagerTemporal.startTask with null user

Author: ClemDoum

datashare-tasks/src/main/java/org/icij/datashare/asynctasks/TaskManagerTemporal.java

@@ -593,8 +593,9 @@ private static <T> T unknownIfNotFound(Function<String, T> function, String task
 
     static SearchAttributes generateSearchAttributes(Task<?> taskView) {
         SearchAttributes.Builder builder = SearchAttributes.newBuilder()
-            .set(USER_CUSTOM_ATTRIBUTE, taskView.getUser().getId())
-            .set(PROGRESS_CUSTOM_ATTRIBUTE, 0d).set(MAX_PROGRESS_CUSTOM_ATTRIBUTE, 0d);
+            .set(PROGRESS_CUSTOM_ATTRIBUTE, 0d)
+            .set(MAX_PROGRESS_CUSTOM_ATTRIBUTE, 0d);
+        Optional.ofNullable(taskView.getUser()).ifPresent(u -> builder.set(USER_CUSTOM_ATTRIBUTE, u.getId()));
         return builder.build();
     }
 

datashare-tasks/src/test/java/org/icij/datashare/asynctasks/TaskManagerTemporalIntTest.java

@@ -116,6 +116,18 @@ public void test_start_task() throws IOException {
         assertThat(task.getState()).isEqualTo(RUNNING);
     }
 
+    @Test
+    public void test_start_task_with_null_user() throws IOException {
+        String expectedTaskId = taskManager.startTask("taskName", null, Map.of("key", "value"));
+
+        List<String> taskIds = taskManager.getTaskIds().toList();
+        assertThat(taskIds).hasSize(1);
+        String taskId = taskIds.get(0);
+        assertThat(taskId).isEqualTo(expectedTaskId);
+        Task<?> task = taskManager.getTask(taskId);
+        assertThat(task.getState()).isEqualTo(RUNNING);
+    }
+
     @Test(timeout = 5000)
     public void test_get_tasks() throws IOException, InterruptedException {
         Task<String> foo = new Task<>("foo", User.local(), Map.of());