diff --git a/api/migrations/20240619192233-updateBCMICollectionTypeField.js b/api/migrations/20240619192233-updateBCMICollectionTypeField.js
deleted file mode 100644
index 6c5687661..000000000
--- a/api/migrations/20240619192233-updateBCMICollectionTypeField.js
+++ /dev/null
@@ -1,74 +0,0 @@
-'use strict';
-
-var dbm;
-var type;
-var seed;
-
-/**
- * Update the 'type' of CollectionBCMI entries
- * Checks each permit in the 'record' array for its typeCode
- * Assigns the type to the Collection based on the permit's typeCode, with ALG having priority
- */
-exports.setup = function(options, seedLink) {
-  dbm = options.dbmigrate;
-  type = dbm.dataType;
-  seed = seedLink;
-};
-
-exports.up = async function(db) {
-  console.log('**** Updating bcmi collections type ****');
-  const mClient = await db.connection.connect(db.connectionString, { native_parser: true });
-
-  try {
-    const nrpti = await mClient.collection('nrpti');
-
-    const collections = await nrpti.find({ _schemaName: 'CollectionBCMI' }).toArray();
-    const permits = await nrpti.find({ _schemaName: { $in: ['Permit', 'PermitBCMI'] } }).toArray();
-
-    let count = 0;
-
-    collections.forEach(async collection => {
-      let typeCode = '';
-      // Go through each record attached to each collection
-      // For each record, check the typeCode
-      const oldType = collection.type;
-      for (const recordId of collection.records) {
-        const record = permits.find(permit => permit._id.toString() == recordId.toString());
-        // ALG takes precedence, so don't overwrite
-        if (record && record.typeCode && typeCode != record.typeCode && typeCode != 'ALG') {
-          typeCode = record.typeCode;
-        }
-      }
-      if (typeCode) {
-        switch (typeCode) {
-          case 'OGP':
-            collection.type = 'Permit';
-            break;
-          case 'ALG':
-            collection.type = 'Amalgamated Permit';
-            break;
-          default:
-            collection.type = 'Permit Amendment';
-        }
-        if (oldType != collection.type) {
-          count += 1;
-          await nrpti.update({ _id: collection._id }, { $set: collection });
-        }
-      }
-    });
-
-    console.log('**** Finished updating ' + count + ' bcmi collection types ****');
-  } catch (error) {
-    console.error(`Migration did not complete. Error processing collections: ${error.message}`);
-  }
-
-  mClient.close();
-};
-
-exports.down = function(db) {
-  return null;
-};
-
-exports._meta = {
-  version: 1
-};
diff --git a/api/src/integrations/core-documents/datasource.js b/api/src/integrations/core-documents/datasource.js
index 9c78b799e..5241c3c12 100644
--- a/api/src/integrations/core-documents/datasource.js
+++ b/api/src/integrations/core-documents/datasource.js
@@ -40,7 +40,7 @@ class CoreDocumentsDataSource {
 
     try {
       // Get Core API access token.
-      this.client_token = await getCoreAccessToken(CORE_CLIENT_ID, CORE_CLIENT_SECRET, CORE_GRANT_TYPE);
+      await this.setClientToken();
 
       // Run main process.
       await this.updateRecords();
@@ -68,17 +68,17 @@ class CoreDocumentsDataSource {
       const jobCount = process.env.PARALLEL_IMPORT_LIMIT ? parseInt(process.env.PARALLEL_IMPORT_LIMIT) : 1;
 
       const permits = await this.getPermits();
-
-      this.status.itemTotal = permits.length;
+      const numPermits = permits.length;
+      this.status.itemTotal = numPermits;
       await this.taskAuditRecord.updateTaskRecord({ itemTotal: this.status.itemTotal });
 
       const permitUtils = new PermitUtils(this.auth_payload, RECORD_TYPE.Permit);
 
       // Push records to proccess into a Promise array to be processed in parallel.
-      for (let i = 0; i < permits.length; i += jobCount) {
+      for (let i = 0; i < numPermits; i += jobCount) {
         const promises = [];
-        for (let j = 0; j < jobCount && i + j < permits.length; j++) {
-          defaultLog.info(`Processing permit ${i + j + 1} out of ${permits.length}`);
+        for (let j = 0; j < jobCount && i + j < numPermits; j++) {
+          defaultLog.info(`Processing permit ${i + j + 1} out of ${numPermits}`);
           promises.push(this.processRecord(permits[i + j], permitUtils));
         }
 
@@ -161,7 +161,9 @@ class CoreDocumentsDataSource {
     if (!documentId) {
       throw new Error('getDownloadToken - param documentId must not be null');
     }
-
+    if (this.isAPITokenExpired(this.apiAccessExpiry)) {
+      this.setClientToken();
+    }
     try {
       const url = getIntegrationUrl(CORE_API_HOST, `/api/download-token/${documentId}`);
       const { token_guid } = await integrationUtils.getRecords(url, getAuthHeader(this.client_token));
@@ -269,12 +271,51 @@ class CoreDocumentsDataSource {
       const transformedAmendment = permitUtils.transformRecord(permit);
       const result = await permitUtils.updateRecord(transformedAmendment, permit);
 
-      if(result.length && result[0].status && result[0].status === 'failure')
+      if (result.length && result[0].status && result[0].status === 'failure')
         throw Error(`permitUtils.updateRecord failed: ${result[0].errorMessage}`);
     } catch (error) {
       throw new Error(`updateAmendment - unexpected error: ${error.message}`);
     }
   }
+
+  /**
+   * Sets the CORE API token and marks when the token will expire
+   *
+   * @memberof CoreDocumentsDataSource
+   */
+  async setClientToken() {
+    console.log('Updating Client Token...');
+    const apiAccess = await getCoreAccessToken(CORE_CLIENT_ID, CORE_CLIENT_SECRET, CORE_GRANT_TYPE);
+    this.apiAccessExpiry = this.getExpiryTime(apiAccess.expires_in);
+    this.client_token = apiAccess.access_token;
+    console.log('Client Token updated.');
+  }
+
+  /**
+   * Gives a time for when the given duration will pass with a buffer
+   *
+   * @param {int} tokenDuration the number of seconds that the token is valid for.
+   * @returns {int} the epoch time when the token is expected to expire ( - the buffer ) = current time + token duration - buffer
+   *
+   * @memberof CoreDocumentsDataSource
+   */
+  getExpiryTime(tokenDuration) {
+    const TIME_BUFFER = 30000;
+    const SECONDS_TO_MILLISECONDS_MULTIPLIER = 1000;
+    return Date.now() + ( tokenDuration * SECONDS_TO_MILLISECONDS_MULTIPLIER ) - TIME_BUFFER;
+  }
+
+  /**
+   * checks if the given time has passed
+   *
+   * @param {int} expiryTime the epoch time we are checking for
+   * @returns {boolean} true if the provided time is in the past
+   *
+   * @memberof CoreDocumentsDataSource
+   */
+  isAPITokenExpired(expiryTime) {
+    return Date.now() >= expiryTime;
+  }
 }
 
 module.exports = CoreDocumentsDataSource;
diff --git a/api/src/integrations/core/datasource.js b/api/src/integrations/core/datasource.js
index c79af8625..211494b31 100644
--- a/api/src/integrations/core/datasource.js
+++ b/api/src/integrations/core/datasource.js
@@ -43,7 +43,8 @@ class CoreDataSource {
 
     try {
       // Get a new API access token.
-      this.client_token = await getCoreAccessToken(CORE_CLIENT_ID, CORE_CLIENT_SECRET, CORE_GRANT_TYPE);
+      const apiAccess = await getCoreAccessToken(CORE_CLIENT_ID, CORE_CLIENT_SECRET, CORE_GRANT_TYPE);
+      this.client_token = apiAccess.access_token;
 
       // Run main process.
       await this.updateRecords();
diff --git a/api/src/integrations/integration-utils.js b/api/src/integrations/integration-utils.js
index afae6c715..8291ba82c 100644
--- a/api/src/integrations/integration-utils.js
+++ b/api/src/integrations/integration-utils.js
@@ -56,7 +56,7 @@ exports.getRecords = async function(url, options = undefined) {
    * @param {string} clientId Core client ID.
    * @param {string} clientSecret Core client secret.
    * @param {string} grantType Core SSO grant type.
-   * @returns {string} Core API access token.
+   * @returns {Object?} payload - the res.data obj which includes the access_token as well as its time to live.
    * @memberof CoreDataSource
    */
   exports.getCoreAccessToken = async function(clientId, clientSecret, grantType) {
@@ -73,9 +73,9 @@ exports.getRecords = async function(url, options = undefined) {
     }
 
     const requestBody = {
-        client_id: clientId,
-        client_secret: clientSecret,
-        grant_type: grantType
+      client_id: clientId,
+      client_secret: clientSecret,
+      grant_type: grantType
     };
 
     const config = {
@@ -92,12 +92,12 @@ exports.getRecords = async function(url, options = undefined) {
       throw new Error('coreLogin - unable to log in to Core API.');
     }
 
-    return payload.access_token;
-  }
+    return payload;
+  };
 
   /**
    * Creates the authentication header for protected requests.
-   * 
+   *
    * @param {string} token Bearer token.
    * @param {object} additionalOptions Additional HTTP options.
    * @returns {object} Axios header with the bearer token set
@@ -110,4 +110,4 @@ exports.getRecords = async function(url, options = undefined) {
       },
       ...additionalOptions
     };
-  }
\ No newline at end of file
+  };
diff --git a/tools/README.md b/tools/README.md
index c2d5b25a7..459daf6d7 100644
--- a/tools/README.md
+++ b/tools/README.md
@@ -66,7 +66,7 @@ Moving the **App** from `dev` (`:latest`) to `test`
 ```sh
 oc project f00029-tools 
 oc tag nrpti:test nrpti:test-backup 
-oc tag nrpti:lastest nrpti:test 
+oc tag nrpti:latest nrpti:test 
 ```
 
 Moving **NRCED** from `dev` (`:latest`) to `test`