adls_2.py 241 B

123
  1. def execute(self, context: "Context") -> Any:
  2. hook = AzureDataLakeHook(azure_data_lake_conn_id=self.azure_data_lake_conn_id)
  3. return hook.remove(path=self.path, recursive=self.recursive, ignore_not_found=self.ignore_not_found)