Skip to content

Instantly share code, notes, and snippets.

@mohan3d
mohan3d / SshSensorOperaror.py
Created February 26, 2021 03:12 — forked from gmic/SshSensorOperaror.py
Airflow ssh sensor
class SshSensorOperator(SSHExecuteOperator, BaseSensorOperator):
"""
Wait for some ssh command to succeed.
"""
count = 0
def poke(self, context):
"""
Function that checks for ssh command.
"""