Creates a PushSource object. Args: name: Name of the push source batch_source: The batch source that backs this push source. It's used when materializing from the offline store to the online store, and when retrieving historical features.
(
self,
*,
name: str,
batch_source: Optional[DataSource] = None,
description: Optional[str] = "",
tags: Optional[Dict[str, str]] = None,
owner: Optional[str] = "",
)
| 858 | batch_source: Optional[DataSource] = None |
| 859 | |
| 860 | def __init__( |
| 861 | self, |
| 862 | *, |
| 863 | name: str, |
| 864 | batch_source: Optional[DataSource] = None, |
| 865 | description: Optional[str] = "", |
| 866 | tags: Optional[Dict[str, str]] = None, |
| 867 | owner: Optional[str] = "", |
| 868 | ): |
| 869 | """ |
| 870 | Creates a PushSource object. |
| 871 | |
| 872 | Args: |
| 873 | name: Name of the push source |
| 874 | batch_source: The batch source that backs this push source. It's used when materializing from the offline |
| 875 | store to the online store, and when retrieving historical features. |
| 876 | description (optional): A human-readable description. |
| 877 | tags (optional): A dictionary of key-value pairs to store arbitrary metadata. |
| 878 | owner (optional): The owner of the data source, typically the email of the primary |
| 879 | maintainer. |
| 880 | """ |
| 881 | super().__init__(name=name, description=description, tags=tags, owner=owner) |
| 882 | self.batch_source = batch_source |
| 883 | |
| 884 | def __eq__(self, other): |
| 885 | if not isinstance(other, PushSource): |