minor fix.

GoogleCloudPlatform · Dec 4, 2023 · 54664b9 · 54664b9
1 parent 929846a
commit 54664b9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/marketing-analytics/activation/data-tasks-coordinator/package.json b/marketing-analytics/activation/data-tasks-coordinator/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@google-cloud/data-tasks-coordinator",
-  "version": "1.9.0",
+  "version": "1.9.1",
   "description": "A data task coordinator based on Cloud Functions",
   "author": "Google Inc.",
   "license": "Apache-2.0",

diff --git a/marketing-analytics/activation/data-tasks-coordinator/src/sentinel.js b/marketing-analytics/activation/data-tasks-coordinator/src/sentinel.js
@@ -127,7 +127,7 @@ class Sentinel {
         const partitionDay = getDatePartition(file.name);
         return Promise.all(taskIds.map((taskId) => {
           this.logger.debug(`Trigger Load task: ${taskId}.`);
-          const parameters = JSON.stringify({ file, partitionDay }); å
+          const parameters = JSON.stringify({ file, partitionDay });
           return this.taskManager.sendTaskMessage(parameters, { taskId });
         }));
       } catch (error) {
@@ -145,7 +145,7 @@ class Sentinel {
    * @private
    */
   async getTaskIdByFile_(fileName) {
-    const regex = /task\[([\w-]*)]/i;
+    const regex = /task[\[|{}]([\w-]*)[\]|}]/i;
     const task = fileName.match(regex);
     if (task) return [task[1]];
     const matchesFileNamePattern = ({ source = {} }) => {
@@ -670,7 +670,7 @@ const getSentinel = async (namespace, database) => {
     validatedStorageTrigger,
   };
   console.log(
-    `Init Sentinel for namespace[${namespace}], Datasource[${database}]`);
+    `Init Sentinel for namespace[${namespace}], Datasource[${database.id}]`);
   return new Sentinel(options);
 };