Auto-download Astra DB SCB

.gitignore

@@ -13,3 +13,5 @@ SIT/**/output/*
 .settings/*
 src/main/main.iml
 src/test/test.iml
+
+**/.claude/settings.local.json

README.md

@@ -155,6 +155,7 @@ spark-submit --properties-file cdm.properties \
 - Fully containerized (Docker and K8s friendly)
 - SSL Support (including custom cipher algorithms)
 - Migrate from any Cassandra `Origin` ([Apache Cassandra®](https://cassandra.apache.org) / [DataStax Enterprise™](https://www.datastax.com/products/datastax-enterprise) / [DataStax Astra DB™](https://www.datastax.com/products/datastax-astra)) to any Cassandra `Target` ([Apache Cassandra®](https://cassandra.apache.org) / [DataStax Enterprise™](https://www.datastax.com/products/datastax-enterprise) / [DataStax Astra DB™](https://www.datastax.com/products/datastax-astra))
+- Automatic download of Secure Connect Bundles for Astra DB using the DevOps API
 - Supports migration/validation from and to [Azure Cosmos Cassandra](https://learn.microsoft.com/en-us/azure/cosmos-db/cassandra)
 - Validate migration accuracy and performance using a smaller randomized data-set
 - Supports adding custom fixed `writetime` and/or `ttl`

RELEASE.md

@@ -1,5 +1,8 @@
 # Release Notes
 
+## [5.3.0] - 2025-05-05
+- Auto-download Astra DB Secure Connect Bundle (SCB) when connecting to Astra DB.
+
 ## [5.2.3] - 2025-04-15
 - Randomized the pending token-range list returned by the `trackRun` feature (when rerunning a previously incomplete job) for better load distribution across the cluster.
 

pom.xml

@@ -175,6 +175,12 @@
 			<version>${mockito.version}</version>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>org.mockito</groupId>
+			<artifactId>mockito-junit-jupiter</artifactId>
+			<version>${mockito.version}</version>
+			<scope>test</scope>
+		</dependency>
 	</dependencies>
 
 	<scm>

src/main/java/com/datastax/cdm/cql/statement/TargetUpsertRunDetailsStatement.java

@@ -114,12 +114,8 @@ public Collection<PartitionRange> getPendingPartitions(long prevRunId, JobType j
 
         final List<PartitionRange> pendingParts = new ArrayList<PartitionRange>();
         // Use an array of statuses for iteration
-        String[] statuses = {
-            TrackRun.RUN_STATUS.NOT_STARTED.toString(),
-            TrackRun.RUN_STATUS.STARTED.toString(),
-            TrackRun.RUN_STATUS.FAIL.toString(),
-            TrackRun.RUN_STATUS.DIFF.toString()
-        };
+        String[] statuses = { TrackRun.RUN_STATUS.NOT_STARTED.toString(), TrackRun.RUN_STATUS.STARTED.toString(),
+                TrackRun.RUN_STATUS.FAIL.toString(), TrackRun.RUN_STATUS.DIFF.toString() };
         for (String status : statuses) {
             pendingParts.addAll(getPartitionsByStatus(prevRunId, status, jobType));
         }