private void updateState ( final TaskStatus . State state ) { statusUpdater . setState ( state ) ; // Commit and push a new status try { statusUpdater . update ( ) ; } catch ( InterruptedException e ) { // TODO: propagate interrupt instead? Thread . currentThread ( ) . interrupt ( ) ; } }
Propagate a new task state by setting it and committing the status update .