タスクの操作

from obshell import ClientSet, TaskExecuteFailedError
from obshell.auth import PasswordAuth

# clientインスタンスを作成します。ノードのアドレスは'10.10.10.1'、ポートは2886です。
# 所在クラスタのroot@sysパスワードは'****'です。
client = ClientSet("10.10.10.1", 2886, PasswordAuth("****"))

try:
    # クラスタを初期化します。
    client.v1.init_sync()
except TaskExecuteFailedError as e:  # クラスタの初期化タスクが失敗した場合をキャッチします。
    client.v1.operate_dag_sync(e.dag-generic_id, "ROLLBACK")  # そのタスクをロールバックします。