(driver_parquet)
| 92 | |
| 93 | @pytest.fixture() |
| 94 | def feast_objects(driver_parquet): |
| 95 | _, parquet_path = driver_parquet |
| 96 | |
| 97 | driver = Entity(name="driver", join_keys=["driver_id"]) |
| 98 | source = FileSource( |
| 99 | name="driver_stats_source", |
| 100 | path=parquet_path, |
| 101 | timestamp_field="event_timestamp", |
| 102 | created_timestamp_column="created", |
| 103 | ) |
| 104 | fv = FeatureView( |
| 105 | name="driver_hourly_stats", |
| 106 | entities=[driver], |
| 107 | ttl=timedelta(days=7), |
| 108 | schema=[ |
| 109 | Field(name="conv_rate", dtype=Float32), |
| 110 | Field(name="acc_rate", dtype=Float32), |
| 111 | Field(name="avg_daily_trips", dtype=Int64), |
| 112 | ], |
| 113 | online=True, |
| 114 | source=source, |
| 115 | ) |
| 116 | fs = FeatureService(name="driver_activity_v1", features=[fv]) |
| 117 | return driver, source, fv, fs |
| 118 | |
| 119 | |
| 120 | def _make_store( |
nothing calls this directly
no test coverage detected