@@ -21,13 +21,16 @@ def sync
2121 @bump_freshness = true
2222 diego_lrps = bbs_apps_client . fetch_scheduling_infos . index_by { |d | d . desired_lrp_key . process_guid }
2323 logger . info ( 'fetched-scheduling-infos' )
24+ log_diego_lrps ( diego_lrps )
25+
2426 logger . info ( 'waiting 15 seconds...' )
2527 sleep 15
2628 logger . info ( 'continuing after 15 seconds...' )
2729 to_desire = [ ]
2830 to_update = { }
2931 batched_processes_for_sync do |processes |
3032 processes . each do |process |
33+ logger . info ( 'process-sync-candidate' , process_guid : process . guid , version_guid : process . version , updated_at : process . updated_at )
3134 process_guid = ProcessGuid . from_process ( process )
3235 diego_lrp = diego_lrps . delete ( process_guid )
3336
@@ -39,9 +42,17 @@ def sync
3942 end
4043 end
4144
45+ logger . info ( 'process-sync-action-start' , action : 'update_lrps' , count : to_update . size )
4246 update_lrps ( to_update )
47+ logger . info ( 'process-sync-action-end' , action : 'update_lrps' , count : to_update . size )
48+
49+ logger . info ( 'process-sync-action-start' , action : 'desire_lrps' , count : to_desire . size )
4350 desire_lrps ( to_desire )
51+ logger . info ( 'process-sync-action-end' , action : 'desire_lrps' , count : to_desire . size )
52+
53+ logger . info ( 'process-sync-action-start' , action : 'delete_lrps' , count : diego_lrps . size )
4454 delete_lrps ( diego_lrps )
55+ logger . info ( 'process-sync-action-end' , action : 'delete_lrps' , count : diego_lrps . size )
4556
4657 workpool . drain
4758
@@ -174,6 +185,21 @@ def bbs_apps_client
174185 CloudController ::DependencyLocator . instance . bbs_apps_client
175186 end
176187
188+ def log_diego_lrps ( diego_lrps )
189+ logger . info ( 'fetched-scheduling-infos-details' , count : diego_lrps . size )
190+
191+ diego_lrps . each do |versioned_process_guid , diego_lrp |
192+ logger . info (
193+ 'fetched-scheduling-info-entry' ,
194+ process_guid : ProcessGuid . cc_process_guid ( versioned_process_guid ) ,
195+ version_guid : ProcessGuid . cc_process_version ( versioned_process_guid ) ,
196+ annotation : diego_lrp . annotation ,
197+ instances : diego_lrp . instances ,
198+ domain : diego_lrp . desired_lrp_key &.domain
199+ )
200+ end
201+ end
202+
177203 def logger
178204 @logger ||= Steno . logger ( 'cc.diego.sync.processes' )
179205 end
0 commit comments