from dagster import asset, with_resources, repository, define_asset_job, SourceAsset
from example_io_manager import my_io_manager

raw_users = SourceAsset(key="raw_users", io_manager_key="test_io_manager")

@asset(io_manager_key="test_io_manager")
def upstream_asset(raw_users):
    #TODO do some transformations
    transformedUsers = raw_users

    return transformedUsers

#TODO what if there are many transformation steps? does each one have to be an asset? can they just be separate ops that work on the asset?

@repository
def repo():
    return [
        *with_resources(
            [ raw_users, upstream_asset ],
            resource_defs={
                "test_io_manager": my_io_manager
            },
        ),
        define_asset_job("process_users"),
    ]