Prefetch Ryuk image with retries

.github/workflows/ci.yml

@@ -458,6 +458,9 @@ jobs:
         run: |
           export MAVEN_OPTS="${MAVEN_INSTALL_OPTS}"
           $RETRY $MAVEN clean install ${MAVEN_FAST_INSTALL} ${MAVEN_GIB} -am -pl "${{ matrix.modules }}"
+      - name: Prefetch Ryuk
+        run: |
+          $RETRY docker pull "$(cat testing/trino-testing-containers/src/main/resources/io/trino/testing/containers/testcontainers-ryuk-image.txt)"
       - name: Maven Tests
         if: matrix.modules != 'plugin/trino-singlestore'
         run: $MAVEN test ${MAVEN_TEST} -pl ${{ matrix.modules }} ${{ matrix.profile != '' && format('-P {0}', matrix.profile) || '' }}

testing/trino-testing-containers/pom.xml

@@ -64,6 +64,12 @@
             <artifactId>testcontainers</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <scope>test</scope>
+        </dependency>
+
         <dependency>
             <groupId>org.testng</groupId>
             <artifactId>testng</artifactId>

testing/trino-testing-containers/src/main/resources/io/trino/testing/containers/testcontainers-ryuk-image.txt

@@ -0,0 +1 @@
+testcontainers/ryuk:0.3.3

testing/trino-testing-containers/src/test/java/io/trino/testing/containers/TestRyukVersion.java

@@ -0,0 +1,51 @@
+/*
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.trino.testing.containers;
+
+import com.github.dockerjava.api.model.Container;
+import com.google.common.io.Resources;
+import org.testcontainers.DockerClientFactory;
+import org.testcontainers.utility.ResourceReaper;
+import org.testng.annotations.Test;
+
+import java.util.List;
+
+import static com.google.common.collect.Iterables.getOnlyElement;
+import static java.nio.charset.StandardCharsets.UTF_8;
+import static org.assertj.core.api.Assertions.assertThat;
+
+public class TestRyukVersion
+{
+    @Test
+    public void testRyukVersionResourceFile()
+            throws Exception
+    {
+        ResourceReaper.instance();
+        List<Container> containers = DockerClientFactory.instance().client()
+                .listContainersCmd().withNameFilter(List.of("testcontainers-ryuk-" + DockerClientFactory.SESSION_ID))
+                .exec();
+        assertThat(containers).as("containers")
+                .hasSize(1);
+
+        String currentImage = getOnlyElement(containers).getImage();
+        // Sanity check the value we get from testcontainers includes version
+        assertThat(currentImage).as("currentImage")
+                .matches("testcontainers/ryuk:(.+)")
+                .doesNotContain("latest");
+
+        String ryukImageFromResource = Resources.toString(Resources.getResource(getClass(), "testcontainers-ryuk-currentImage.txt"), UTF_8).trim();
+        assertThat(ryukImageFromResource).as("ryukImageFromResource")
+                .isEqualTo(currentImage);
+    }
+}