dagster

from dagster import Definitions, asset, job @asset def my_first_asset(): """A simple asset that prints a message and returns a string.""" print("Hello, Dagster!") return "hello" @job def my_asset_job(): my_first_asset() # To run this locally and see the output immediately: if __name__ == "__main__": from dagster import materialize_to_memory result = materialize_to_memory(assets=[my_first_asset]) assert result.success print(f"Asset output: {result.output_for_node('my_first_asset')}") # For UI (Dagit) integration, save the following `Definitions` to a file (e.g., `my_repo.py`): # defs = Definitions( # assets=[my_first_asset], # jobs=[my_asset_job], # ) # Then run `dagster dev -f my_repo.py` and navigate to http://localhost:3000