Suresh R
'Running' object has no attribute 'is_success'
def post_to_cw(obj, old_state, new_state): if new_state.is_failed(): cloudwatch.put_metrics(cid=CID, flow_name=FLOW_NAME, status_code=1) if new_state.is_success(): cloudwatch.put_metrics(cid=CID, flow_name=FLOW_NAME, status_code=0) return new_state
Kevin Kho
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.