Fix api url missing scheme

datasprayio · Jan 6, 2025 · c8124e4 · c8124e4
1 parent fcaa331
commit c8124e4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...er-parent/dataspray-runner-java/src/main/java/io/dataspray/runner/RawCoordinatorImpl.java b/...er-parent/dataspray-runner-java/src/main/java/io/dataspray/runner/RawCoordinatorImpl.java
@@ -112,7 +112,9 @@ private IngestApi getIngestApi() {
                     }
 
                     // Fetch endpoint
-                    Optional<String> endpointOpt = Optional.ofNullable(Strings.emptyToNull(System.getenv(DATASPRAY_ENDPOINT_ENV)));
+                    Optional<String> endpointOpt = Optional.ofNullable(Strings.emptyToNull(System.getenv(DATASPRAY_ENDPOINT_ENV)))
+                            .map(endpoint -> endpoint.matches("^https?://")
+                                    ? endpoint : "https://" + endpoint);
 
                     ingestApiOpt = Optional.of(DataSprayClient.get(new Access(
                                     apiKey,