Skip to content

Commit

Permalink
Fix file formats
Browse files Browse the repository at this point in the history
  • Loading branch information
renan-souza committed Dec 11, 2024
1 parent 6c8401c commit ca1f2d9
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 1 deletion.
4 changes: 4 additions & 0 deletions src/flowcept/commons/daos/docdb_dao/lmdb_dao.py
Original file line number Diff line number Diff line change
Expand Up @@ -304,14 +304,18 @@ def close(self):
self._is_closed = True

def object_query(self, filter):
"""Query objects collection."""
raise NotImplementedError

def dump_to_file(self, collection_name, filter, output_file, export_format, should_zip):
"""Dump data to file."""
raise NotImplementedError

def save_object(self, object, object_id, task_id, workflow_id, type, custom_metadata,
save_data_in_collection, pickle_):
"""Save object."""
raise NotImplementedError

def get_file_data(self, file_id):
"""Get file data."""
raise NotImplementedError
1 change: 0 additions & 1 deletion src/flowcept/configs.py
Original file line number Diff line number Diff line change
@@ -1,5 +1,4 @@
"""Configuration module."""
import logging
import os
import socket
import getpass
Expand Down
1 change: 1 addition & 0 deletions src/flowcept/flowcept_api/db_api.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ def _dao(cls) -> DocumentDBDAO:
return DocumentDBDAO.get_instance(create_indices=False)

def close(self):
"""Close DB resources."""
DBAPI._dao.close()

def insert_or_update_task(self, task: TaskObject):
Expand Down

0 comments on commit ca1f2d9

Please sign in to comment.