Skip to content

Commit

Permalink
fix first party refernces to use kwargs only
Browse files Browse the repository at this point in the history
Signed-off-by: Achal Shah <[email protected]>
  • Loading branch information
achals committed Apr 5, 2022
1 parent ea85086 commit f5fc225
Show file tree
Hide file tree
Showing 4 changed files with 20 additions and 18 deletions.
32 changes: 17 additions & 15 deletions sdk/python/feast/data_source.py
Original file line number Diff line number Diff line change
Expand Up @@ -209,9 +209,11 @@ def __init__(
"""
if not name:
warnings.warn(
("Names for data sources need to be supplied. "
"Data sources without names will no tbe supported after Feast 0.23."),
UserWarning
(
"Names for data sources need to be supplied. "
"Data sources without names will no tbe supported after Feast 0.23."
),
UserWarning,
)
self.name = name or ""
self.event_timestamp_column = (
Expand Down Expand Up @@ -348,14 +350,14 @@ def __init__(
owner: Optional[str] = "",
):
super().__init__(
name,
event_timestamp_column,
created_timestamp_column,
field_mapping,
date_partition_column,
event_timestamp_column=event_timestamp_column,
created_timestamp_column=created_timestamp_column,
field_mapping=field_mapping,
date_partition_column=date_partition_column,
description=description,
tags=tags,
owner=owner,
name=name,
)
self.kafka_options = KafkaOptions(
bootstrap_servers=bootstrap_servers,
Expand Down Expand Up @@ -446,7 +448,7 @@ def __init__(
owner: Optional[str] = "",
):
"""Creates a RequestDataSource object."""
super().__init__(name, description=description, tags=tags, owner=owner)
super().__init__(name=name, description=description, tags=tags, owner=owner)
self.schema = schema

def validate(self, config: RepoConfig):
Expand Down Expand Up @@ -544,11 +546,11 @@ def __init__(
owner: Optional[str] = "",
):
super().__init__(
name,
event_timestamp_column,
created_timestamp_column,
field_mapping,
date_partition_column,
name=name,
event_timestamp_column=event_timestamp_column,
created_timestamp_column=created_timestamp_column,
field_mapping=field_mapping,
date_partition_column=date_partition_column,
description=description,
tags=tags,
owner=owner,
Expand Down Expand Up @@ -628,7 +630,7 @@ def __init__(
owner (optional): The owner of the data source, typically the email of the primary
maintainer.
"""
super().__init__(name, description=description, tags=tags, owner=owner)
super().__init__(name=name, description=description, tags=tags, owner=owner)
self.schema = schema
self.batch_source = batch_source
if not self.batch_source:
Expand Down
2 changes: 1 addition & 1 deletion sdk/python/feast/infra/offline_stores/bigquery_source.py
Original file line number Diff line number Diff line change
Expand Up @@ -86,7 +86,7 @@ def __init__(
)

super().__init__(
_name if _name else "",
name=_name if _name else "",
event_timestamp_column=event_timestamp_column,
created_timestamp_column=created_timestamp_column,
field_mapping=field_mapping,
Expand Down
2 changes: 1 addition & 1 deletion sdk/python/feast/infra/offline_stores/redshift_source.py
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ def __init__(
)

super().__init__(
_name if _name else "",
name=_name if _name else "",
event_timestamp_column=event_timestamp_column,
created_timestamp_column=created_timestamp_column,
field_mapping=field_mapping,
Expand Down
2 changes: 1 addition & 1 deletion sdk/python/feast/infra/offline_stores/snowflake_source.py
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ def __init__(
)

super().__init__(
_name if _name else "",
name=_name if _name else "",
event_timestamp_column=event_timestamp_column,
created_timestamp_column=created_timestamp_column,
field_mapping=field_mapping,
Expand Down

0 comments on commit f5fc225

Please sign in to comment.