File tree Expand file tree Collapse file tree 1 file changed +12
-5
lines changed
Expand file tree Collapse file tree 1 file changed +12
-5
lines changed Original file line number Diff line number Diff line change @@ -131,11 +131,18 @@ def process_feed_references(self, session: "Session"):
131131 except ValueError :
132132 gtfs_stable_id = static_reference
133133 gtfs_feed = self .query_feed_by_stable_id (session , gtfs_stable_id , "gtfs" )
134- already_referenced_ids = {ref .id for ref in gtfs_feed .gtfs_rt_feeds }
135- if gtfs_feed and gtfs_rt_feed .id not in already_referenced_ids :
136- gtfs_feed .gtfs_rt_feeds .append (gtfs_rt_feed )
137- # Flush to avoid FK violation
138- session .flush ()
134+ if gtfs_feed :
135+ # Add a None check for gtfs_rt_feeds
136+ if gtfs_feed .gtfs_rt_feeds is not None :
137+ already_referenced_ids = {ref .id for ref in gtfs_feed .gtfs_rt_feeds }
138+ if gtfs_rt_feed and gtfs_rt_feed .id not in already_referenced_ids :
139+ gtfs_feed .gtfs_rt_feeds .append (gtfs_rt_feed )
140+ # Flush to avoid FK violation
141+ session .flush ()
142+ else :
143+ self .logger .warning (f"GTFS feed { gtfs_stable_id } has no gtfs_rt_feeds attribute." )
144+ else :
145+ self .logger .warning (f"GTFS feed with stable ID { gtfs_stable_id } not found." )
139146
140147 def process_redirects (self , session : "Session" ):
141148 """
You can’t perform that action at this time.
0 commit comments