Skip to content

Commit

Permalink
make outs optional
Browse files Browse the repository at this point in the history
  • Loading branch information
cbini committed Sep 14, 2023
1 parent 59f0859 commit 8361c13
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions src/teamster/core/fivetran/assets.py
Original file line number Diff line number Diff line change
Expand Up @@ -58,6 +58,7 @@ def build_fivetran_assets(
dagster_type=Nothing,
io_manager_key=io_manager_key,
metadata=_metadata_by_table_name.get(table),
is_required=False,
)
for table, key in tracked_asset_keys.items()
},
Expand All @@ -68,7 +69,6 @@ def build_fivetran_assets(
can_subset=True,
)
def _assets(context: OpExecutionContext) -> Any:
# materialized_asset_keys = set()
for materialization in generate_materializations(context.selected_asset_keys):
# scan through all tables actually created,
# if it was expected then emit an Output.
Expand All @@ -79,7 +79,6 @@ def _assets(context: OpExecutionContext) -> Any:
output_name="_".join(materialization.asset_key.path),
metadata=materialization.metadata,
)
# materialized_asset_keys.add(materialization.asset_key)
# else:
# yield materialization

Expand Down

0 comments on commit 8361c13

Please sign in to comment.