Sha256: e6ca2584f69eae45f28cdbc5056aa7f91b9f2e0e9407d3d4223cec1d3d9dc7b9
Contents?: true
Size: 605 Bytes
Versions: 6
Compression:
Stored size: 605 Bytes
Contents
package org.embulk.executor.remoteserver;
import com.github.kamatama41.nsocket.Command;
import com.github.kamatama41.nsocket.Connection;
class UpdateTaskStateCommand implements Command<UpdateTaskStateData> {
static final String ID = "update_task_state";
private final ClientSession session;
UpdateTaskStateCommand(ClientSession session) {
this.session = session;
}
@Override
public void execute(UpdateTaskStateData data, Connection connection) throws Exception {
session.update(data);
}
@Override
public String getId() {
return ID;
}
}
Version data entries
6 entries across 6 versions & 1 rubygems