diff --git a/noncore/_utils/rfcx-audio/audio-transcode.js b/noncore/_utils/rfcx-audio/audio-transcode.js
index 98e24c541..a0df14669 100644
--- a/noncore/_utils/rfcx-audio/audio-transcode.js
+++ b/noncore/_utils/rfcx-audio/audio-transcode.js
@@ -112,7 +112,8 @@ exports.audioUtils = {
                 reject(err)
               })
               .on('end', function () {
-                if (!inputParams.keepFile) {
+                // Don't remove source file if ingest service is enabled
+                if (process.env.INGEST_SERVICE_ENABLED !== 'true') {
                   fs.unlink(inputParams.sourceFilePath, function (e) { if (e) { console.error(e) } })
                 }
                 resolve(transcodedFilePath)
diff --git a/noncore/_utils/rfcx-mqtt/mqtt-checkin-assets.js b/noncore/_utils/rfcx-mqtt/mqtt-checkin-assets.js
index e69d75a5f..9400d628f 100644
--- a/noncore/_utils/rfcx-mqtt/mqtt-checkin-assets.js
+++ b/noncore/_utils/rfcx-mqtt/mqtt-checkin-assets.js
@@ -39,6 +39,7 @@ exports.checkInAssets = {
                   if (err) { console.error(err); reject(err) }
 
                   checkInObj.audio.meta.captureSampleCount = parseInt(stdout.trim())
+                  assetUtils.deleteLocalFileFromFileSystem(wavFilePath)
                   resolve(checkInObj)
                 })
               })