equal
deleted
inserted
replaced
884 update_running(db, state.running, old_state.running), |
884 update_running(db, state.running, old_state.running), |
885 update_results(db, state.results, old_state.results)) |
885 update_results(db, state.results, old_state.results)) |
886 |
886 |
887 if (updates.exists(_.defined)) { |
887 if (updates.exists(_.defined)) { |
888 val serial = state.next_serial |
888 val serial = state.next_serial |
889 write_updates(db, serial, updates) |
889 // FIXME write_updates(db, serial, updates) |
890 stamp_worker(db, worker_uuid, serial) |
890 stamp_worker(db, worker_uuid, serial) |
891 state.copy(serial = serial) |
891 state.copy(serial = serial) |
892 } |
892 } |
893 else state |
893 else state |
894 } |
894 } |