adls_4.py 249 B

1234
  1. def execute(self, context: "Context") -> list:
  2. hook = AzureDataLakeHook(azure_data_lake_conn_id=self.azure_data_lake_conn_id)
  3. self.log.info('Getting list of ADLS files in path: %s', self.path)
  4. return hook.list(path=self.path)