Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion api/src/shared/database/database.py
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ def refresh_materialized_view(session: "Session", view_name: str) -> bool:
session.execute(text(f"REFRESH MATERIALIZED VIEW CONCURRENTLY {view_name}"))
return True
except Exception as error:
logging.error(f"Error raised while refreshing view: {error}")
logging.error("Error raised while refreshing view: %s", error)
return False


Expand Down
2 changes: 1 addition & 1 deletion functions-python/helpers/feed_status.py
Original file line number Diff line number Diff line change
Expand Up @@ -70,7 +70,7 @@ def get_filters(status: str):
.update({Feed.status: status}, synchronize_session=False)
)
except Exception as e:
logging.error(f"Error updating feed statuses: {e}")
logging.error("Error updating feed statuses: %s", e)
raise Exception(f"Error updating feed statuses: {e}")

try:
Expand Down
5 changes: 2 additions & 3 deletions functions-python/update_feed_status/src/main.py
Original file line number Diff line number Diff line change
@@ -1,17 +1,16 @@
import logging
import functions_framework
from shared.helpers.logger import Logger
from shared.helpers.logger import init_logger
from shared.helpers.feed_status import update_feed_statuses_query
from shared.database.database import with_db_session

logging.basicConfig(level=logging.INFO)
init_logger()


@with_db_session
@functions_framework.http
def update_feed_status(_, db_session):
"""Updates the Feed status based on the latets dataset service date range."""
Logger.init_logger()
try:
logging.info("Database session started.")
diff_counts = update_feed_statuses_query(db_session, [])
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -108,9 +108,8 @@ def test_update_feed_status_failed_query():
assert str(e) == "Error updating feed statuses: Mocked exception"


@patch("main.Logger", autospec=True)
@patch("main.update_feed_statuses_query")
def test_updated_feed_status(mock_update_query, mock_logger):
def test_updated_feed_status(mock_update_query):
return_value = {"active": 5}
mock_update_query.return_value = return_value

Expand All @@ -122,9 +121,8 @@ def test_updated_feed_status(mock_update_query, mock_logger):
assert status_code == 200


@patch("main.Logger", autospec=True)
@patch("main.update_feed_statuses_query")
def test_updated_feed_status_error_raised(mock_update_query, mock_logger):
def test_updated_feed_status_error_raised(mock_update_query):
mock_update_query.side_effect = Exception("Mocked exception")

with patch.dict(os.environ, {"FEEDS_DATABASE_URL": default_db_url}):
Expand Down