diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/DefaultGetSpecWorker.java b/airbyte-workers/src/main/java/io/airbyte/workers/DefaultGetSpecWorker.java index fb01f9504d421..60e3438fd1c45 100644 --- a/airbyte-workers/src/main/java/io/airbyte/workers/DefaultGetSpecWorker.java +++ b/airbyte-workers/src/main/java/io/airbyte/workers/DefaultGetSpecWorker.java @@ -56,8 +56,9 @@ public OutputAndStatus run(JobGetSpecConfig config, Path LineGobbler.gobble(process.getErrorStream(), LOGGER::error); try (InputStream stdout = process.getInputStream()) { - // retrieving spec should generally be instantaneous - WorkerUtils.gentleClose(process, 10, TimeUnit.SECONDS); + // retrieving spec should generally be instantaneous, but since docker images might not be pulled + // it could take a while longer depending on internet conditions as well. + WorkerUtils.gentleClose(process, 2, TimeUnit.MINUTES); if (process.exitValue() == 0) { String specString = new String(stdout.readAllBytes());