|
16 | 16 |
|
17 | 17 | package com.google.cloud.spanner.it; |
18 | 18 |
|
19 | | -import static com.google.common.base.Strings.isNullOrEmpty; |
20 | 19 | import static com.google.common.truth.Truth.assertThat; |
21 | 20 | import static org.junit.Assert.assertThrows; |
22 | 21 | import static org.junit.Assume.assumeTrue; |
@@ -66,22 +65,14 @@ public static List<DialectTestParameter> data() { |
66 | 65 |
|
67 | 66 | private static DatabaseClient client; |
68 | 67 |
|
69 | | - private static boolean isUsingCloudDevel() { |
70 | | - String jobType = System.getenv("JOB_TYPE"); |
71 | | - |
72 | | - // Assumes that the jobType contains the string "cloud-devel" to signal that |
73 | | - // the environment is cloud-devel. |
74 | | - return !isNullOrEmpty(jobType) && jobType.contains("cloud-devel"); |
75 | | - } |
76 | | - |
77 | 68 | private Struct readRow(String queue, Key key, String... columns) { |
78 | 69 | return client.singleUse(TimestampBound.strong()).readRow(queue, key, Arrays.asList(columns)); |
79 | 70 | } |
80 | 71 |
|
81 | 72 | @BeforeClass |
82 | 73 | public static void setUpTestSuite() { |
83 | 74 | // TODO: remove once the feature is fully enabled in prod |
84 | | - assumeTrue("Queue is currently only supported in cloud-devel", isUsingCloudDevel()); |
| 75 | + assumeTrue("Queue tests are temporarily disabled", false); |
85 | 76 | Database googleStandardSQLDatabase = |
86 | 77 | env.getTestHelper().createTestDatabase(GOOGLE_STANDARD_SQL_SCHEMA); |
87 | 78 | googleStandardSQLClient = env.getTestHelper().getDatabaseClient(googleStandardSQLDatabase); |
|
0 commit comments