def METHOD_NAME(self) -> Flow:
    if self.parallel:
        # generate a separate task for each account
        supermetrics_downloads = apply_map(
            self.gen_supermetrics_task, self.ds_accounts, flow=self
        )
    else:
        supermetrics_downloads = self.gen_supermetrics_task(
            ds_accounts=self.ds_accounts, flow=self
        )
    csv_to_blob_storage_task = BlobFromCSV(timeout=self.timeout)
    csv_to_blob_storage_task.bind(
        from_path=self.local_file_path,
        to_path=self.blob_path,
        overwrite=self.overwrite_blob,
        flow=self,
    )
    blob_to_azure_sql_task = CreateTableFromBlob(timeout=self.timeout)
    blob_to_azure_sql_task.bind(
        blob_path=self.blob_path,
        schema=self.schema,
        table=self.table,
        dtypes=self.dtypes,
        sep=self.sep,
        if_exists=self.if_exists,
        flow=self,
    )
    csv_to_blob_storage_task.set_upstream(supermetrics_downloads, flow=self)
    blob_to_azure_sql_task.set_upstream(csv_to_blob_storage_task, flow=self)