Skip to content

Commit

Permalink
fixup! Issue #635: cleaner job manager API for initializing the job d…
Browse files Browse the repository at this point in the history
…atabase
  • Loading branch information
soxofaan committed Oct 7, 2024
1 parent f88d307 commit 35f6917
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions openeo/extra/job_management.py
Original file line number Diff line number Diff line change
Expand Up @@ -259,7 +259,7 @@ def _make_resilient(connection):
connection.session.mount("http://", HTTPAdapter(max_retries=retries))

@staticmethod
def __normalize_df__(df: pd.DataFrame) -> pd.DataFrame:
def _normalize_df(df: pd.DataFrame) -> pd.DataFrame:
"""
Normalize given pandas dataframe (creating a new one):
ensure we have the required columns.
Expand Down Expand Up @@ -713,7 +713,7 @@ def initialize_from_df(self, df: pd.DataFrame):
# TODO: option to provide custom MultiBackendJobManager subclass with custom normalize?
if self.exists():
raise RuntimeError(f"Job database {self!r} already exists.")
df = MultiBackendJobManager.__normalize_df__(df)
df = MultiBackendJobManager._normalize_df(df)
self.persist(df)
# Return self to allow chaining with constructor.
return self
Expand Down

0 comments on commit 35f6917

Please sign in to comment.