def METHOD_NAME(self) -> Flow:
    df_task = ASELiteToDF(timeout=self.timeout)
    df = df_task.bind(
        query=self.query,
        credentials_secret=self.sqldb_credentials_secret,
        vault_name=self.vault_name,
        flow=self,
    )
    if self.convert_bytes == True:
        df = df_converts_bytes_to_int.bind(df, flow=self)
    if self.remove_special_characters == True:
        df = df_clean_column(df, columns_to_clean=self.columns_to_clean, flow=self)
    create_csv = df_to_csv.bind(
        df,
        path=self.file_path,
        sep=self.sep,
        if_exists=self.if_exists,
        flow=self,
    )
    file_to_adls_task = AzureDataLakeUpload(timeout=self.timeout)
    adls_upload = file_to_adls_task.bind(
        from_path=self.file_path,
        to_path=self.to_path,
        overwrite=self.overwrite,
        sp_credentials_secret=self.sp_credentials_secret,
        flow=self,
    )
    create_csv.set_upstream(df, flow=self)
    adls_upload.set_upstream(create_csv, flow=self)