fiftyone.pipeline.engines
Advanced tools
Comparing version 4.4.79 to 4.4.80
@@ -166,3 +166,3 @@ /* ********************************************************************* | ||
return false; | ||
} | ||
}; | ||
@@ -173,2 +173,3 @@ const filename = dataFile.tempDataDirectory + | ||
response.pipe(fs.createWriteStream(filename)); | ||
@@ -178,3 +179,2 @@ | ||
// Open file | ||
if (dataFile.verifyMD5) { | ||
@@ -310,2 +310,5 @@ const headerMD5 = response.headers['content-md5']; | ||
dataFileUpdateService.fileReady(dataFile, doneFileName); | ||
fs.unlink(filename, function (err) { | ||
if (err) dataFileUpdateService.pipeline.log('error', err); | ||
}); | ||
}); | ||
@@ -329,22 +332,24 @@ }); | ||
let interval = minToMs( | ||
(Math.floor(Math.random() * | ||
dataFile.updateTimeMaximumRandomisation) + | ||
1) + | ||
dataFile.pollingInterval | ||
); | ||
interval += dataFile.getNextUpdate().getMilliseconds(); | ||
// Run update on start if specified to do so | ||
if (dataFile.updateOnStart && !dataFile.attemptedDownload) { | ||
dataFileUpdateService.updateDataFile(dataFile); | ||
} else { | ||
return; | ||
} | ||
if(dataFile.autoUpdate) { | ||
let interval = minToMs( | ||
(Math.floor(Math.random() * | ||
dataFile.updateTimeMaximumRandomisation) + | ||
1) + | ||
dataFile.pollingInterval | ||
); | ||
interval += dataFile.getNextUpdate().getMilliseconds(); | ||
setTimeout(function () { | ||
dataFileUpdateService.updateDataFile(dataFile); | ||
}, interval); | ||
return; | ||
} | ||
} catch (e) { | ||
// Catch any extra errors with datafile updates | ||
this.pipeline.log('error', e); | ||
@@ -361,3 +366,2 @@ } | ||
dataFile.registered = true; | ||
if (dataFile.updateOnStart) { | ||
@@ -364,0 +368,0 @@ this.updateDataFile(dataFile); |
{ | ||
"name": "fiftyone.pipeline.engines", | ||
"version": "4.4.79", | ||
"version": "4.4.80", | ||
"description": "Shared base functionality for implementing engines for the 51Degrees Pipeline API", | ||
@@ -5,0 +5,0 @@ "keywords": [ |
89142
2304