Skip to content

Commit

Permalink
use stream definition for group
Browse files Browse the repository at this point in the history
  • Loading branch information
cnolanminich committed Jul 29, 2024
1 parent 687736e commit dff90f8
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion hooli-demo-assets/hooli_demo_assets/assets/sling.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,10 @@ def __init__(self, target_prefix="RAW_DATA"):
self.replication_config = replication_config

def get_group_name(self, stream_definition):
return "RAW_DATA"
for key, value in stream_definition['config'].items():
if value == 'locations':
group_name = 'RAW_DATA'
return group_name

def get_tags(self, stream_definition):
# derive storage_kind from the target set in the replication_config
Expand Down

0 comments on commit dff90f8

Please sign in to comment.