Ошибка воздушного потока Python AttributeError: у объекта 'xsensor' нет атрибута 'l' - PullRequest
Новая
       8

Ошибка воздушного потока Python AttributeError: у объекта 'xsensor' нет атрибута 'l'

0 голосов
/ 02 июля 2019

Я новичок в Python и воздушного потока. Попытка реализовать датчик, как показано ниже, и ошибка говорит: «AttributeError: у объекта 'mySensor' нет атрибута 'l'" от. Может ли кто-нибудь помочь пролить свет на это? Ниже приведен целый класс для mySensor. Большое спасибо. 

class mySensor(SFTPSensor):
"""
Subclass of SFTPSensor to override the poke() method 
"""
template_fields = "previous_month"

@apply_defaults
def __init__(self,
             last_day_previous_month,
             *args,
             **kwargs):
    self.previous_month = previous_month
    super(mySensor, self).__init__(*args, **kwargs)

def poke(self, context):
    remote_path = self.path+"file_to_check"+self.previous_month
    file_count = len(self.hook.list_directory(remote_path))
    if file_count == 0:
        return False
    else:
        logging.info("Found %d files", file_count)
        return True

и где я использовал датчик 

sensor_task = mySensor(
                    previous_month=_previous_month_template,
                    task_id="check-remote-files",
                    dag=dag,
                    sftp_conn_id=my_conn_id,
                    path="/my/path/"
                    )
...