add sink name to generate_batch_id (#22)

hotgluexyz · Jan 21, 2025 · d6d690f · d6d690f
1 parent b8026c2
commit d6d690f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/target_api/sinks.py b/target_api/sinks.py
@@ -87,7 +87,7 @@ def make_batch_request(self, records: List[dict]):
 
     def generate_batch_id(self):
         index = math.ceil(self._total_records_read/self.max_size)
-        external_id = f"{os.environ.get('JOB_ROOT', 'job_Example')}:{index}"
+        external_id = f"{os.environ.get('JOB_ROOT', 'job_Example')}:{self.name}:{index}"
         external_id = hashlib.md5(external_id.encode()).hexdigest()
         return external_id