async def METHOD_NAME(self, profile: Profile):
    self.logger.info("> sync_created()")
    # find all known schema ids that i created...
    session = await profile.session()
    storage = session.inject(BaseStorage)
    schema_ids = await storage.find_all_records(
        type_filter=SCHEMA_SENT_RECORD_TYPE,
        tag_query={},
    )
    self.logger.debug(f"created count = {len(schema_ids)}")
    # for all found... go get details from ledger and put schema into storage.
    for schema_id in schema_ids:
        await self.add_item(profile, schema_id.value)
    records = await self.list_items(profile)
    self.logger.info(f"< sync_created(): {len(records)}")
    return records