Fixed decode function and table.data

CHANGELOG.md

@@ -102,6 +102,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Fix the ordering and sequencing of jobs initiated on `db.apply`
 - Fix rest routes with db injection and prefix.
 - Fix cluster db setter.
+- Fix decode function
 
 ## [0.3.0](https://github.com/superduper-io/superduper/compare/0.3.0...0.2.0])    (2024-Jun-21)
 

superduper/backends/local/compute.py

@@ -67,6 +67,9 @@ def submit(self, job: Job) -> str:
         self.db.metadata.update_job(job.identifier, 'status', 'running')
 
         try:
+            logging.debug(
+                f'Running job {job.job_id}: {component.identifier}.{job.method}'
+            )
             method = getattr(component, job.method)
             output = method(*args, **kwargs)
         except Exception as e:

superduper/backends/local/crontab.py

@@ -1,6 +1,7 @@
 from superduper.backends.base.crontab import CrontabBackend
 
 
+# TODO: implement this
 class LocalCrontabBackend(CrontabBackend):
     """Local crontab backend."""
 
@@ -20,7 +21,7 @@ def list_components(self):
 
     def list_uuids(self):
         """List UUIDs of components."""
-        raise NotImplementedError
+        return []
 
     def drop(self):
         """Drop the crontab."""

superduper/base/document.py

@@ -569,7 +569,7 @@ def _get_leaf_from_cache(k, builds, getters, db: t.Optional['Datalayer'] = None)
     for other in keys:
         import re
 
-        matches = re.findall(f'.*\?\(({k}\..*)\)', other)
+        matches = re.findall(f'.*\?\(({k}\..*?)\)', other)
         old_other = other[:]
         if matches:
             for match in matches:

superduper/components/table.py

@@ -69,4 +69,5 @@ def add_data(self):
             data = self.data.data
         else:
             data = self.data
-        self.db[self.identifier].insert(data).execute()
+        if data:
+            self.db[self.identifier].insert(data).execute()