File tree Expand file tree Collapse file tree 2 files changed +0
-7
lines changed
src/datachain/data_storage Expand file tree Collapse file tree 2 files changed +0
-7
lines changed Original file line number Diff line number Diff line change @@ -421,10 +421,6 @@ def set_job_and_dataset_status(
421421 ) -> None :
422422 """Set the status of the given job and dataset."""
423423
424- @abstractmethod
425- def get_possibly_stale_jobs (self ) -> list [tuple [str , str , int ]]:
426- """Returns the possibly stale jobs."""
427-
428424
429425class AbstractDBMetastore (AbstractMetastore ):
430426 """
Original file line number Diff line number Diff line change @@ -496,9 +496,6 @@ def _dataset_dependencies_select_columns(self) -> list["SchemaItem"]:
496496 def _jobs_insert (self ) -> "Insert" :
497497 return sqlite .insert (self ._jobs )
498498
499- def get_possibly_stale_jobs (self ) -> list [tuple [str , str , int ]]:
500- raise NotImplementedError ("get_possibly_stale_jobs not implemented for SQLite" )
501-
502499
503500class SQLiteWarehouse (AbstractWarehouse ):
504501 """
You can’t perform that action at this time.
0 commit comments