926 val updates = |
926 val updates = |
927 List( |
927 List( |
928 update_sessions(db, state.sessions, old_state.sessions), |
928 update_sessions(db, state.sessions, old_state.sessions), |
929 update_pending(db, state.pending, old_state.pending), |
929 update_pending(db, state.pending, old_state.pending), |
930 update_running(db, state.running, old_state.running), |
930 update_running(db, state.running, old_state.running), |
931 update_results(db, state.results, old_state.results)) |
931 update_results(db, state.results, old_state.results) |
932 |
932 ).filter(_.defined) |
933 if (updates.exists(_.defined)) { |
933 |
|
934 if (updates.nonEmpty) { |
934 val serial = state.next_serial |
935 val serial = state.next_serial |
935 write_updates(db, build_id, serial, updates) |
936 write_updates(db, build_id, serial, updates) |
936 stamp_worker(db, worker_uuid, serial) |
937 stamp_worker(db, worker_uuid, serial) |
937 state.copy(serial = serial) |
938 state.copy(serial = serial) |
938 } |
939 } |