|
26 | 26 | from gtfs_diff.engine import diff_feeds |
27 | 27 | from sqlalchemy.dialects.postgresql import insert |
28 | 28 | from sqlalchemy.orm import Session |
| 29 | +from sqlalchemy.sql import func |
29 | 30 |
|
30 | 31 | from shared.common.gcp_memory_utils import limit_gcp_memory |
31 | 32 | from shared.database.database import with_db_session |
@@ -101,12 +102,18 @@ def gtfs_change_tracker(request: flask.Request) -> dict: |
101 | 102 | # return HTTP 200 to suppress GCP retries. If a specific exception type is |
102 | 103 | # identified as safely retriable in the future, catch it here and return 500. |
103 | 104 | logging.exception( |
104 | | - "Failed to generate changelog for %s -> %s", |
| 105 | + "Failed to generate changelog for feed=%s base=%s new=%s", |
| 106 | + feed_stable_id, |
105 | 107 | base_dataset_stable_id, |
106 | 108 | new_dataset_stable_id, |
107 | 109 | ) |
108 | 110 | return flask.make_response( |
109 | | - {"status": "error", "error": f"Failed to generate changelog: {e}"}, 200 |
| 111 | + { |
| 112 | + "status": "error", |
| 113 | + "error": f"Failed to generate changelog: {e}", |
| 114 | + "payload": payload, |
| 115 | + }, |
| 116 | + 200, |
110 | 117 | ) |
111 | 118 |
|
112 | 119 |
|
@@ -307,7 +314,7 @@ def _save_changelog_record( |
307 | 314 | set_={ |
308 | 315 | "changelog_url": changelog_url, |
309 | 316 | "diff_summary": diff_summary, |
310 | | - "generated_at": GtfsDatasetChangelog.generated_at.default, |
| 317 | + "generated_at": func.now(), |
311 | 318 | }, |
312 | 319 | ) |
313 | 320 | ) |
|
0 commit comments