Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Feast apply Error #24

Open
SuperEllipse opened this issue Nov 26, 2022 · 0 comments
Open

Feast apply Error #24

SuperEllipse opened this issue Nov 26, 2022 · 0 comments

Comments

@SuperEllipse
Copy link

SuperEllipse commented Nov 26, 2022

Feast version 0.21
Hive table structure :
event_timestamp timestamp
driver_id bigint
conv_rate float
acc_rate float
avg_daily_trips int
created timestamp
Example.py

from google.protobuf.duration_pb2 import Duration

from feast import Entity, Feature, FeatureView, ValueType
from feast_hive import HiveSource

driver_hourly_stats = HiveSource(
# table='driver_stats',
query = """
SELECT event_timestamp,
driver_id, conv_rate, acc_rate, avg_daily_trips,
created
FROM feast_offline_store.driver_stats
""",
event_timestamp_column="event_timestamp",
created_timestamp_column="created",
)

Define an entity for the driver.

driver = Entity(name="driver_id", value_type=ValueType.INT64, description="driver id", )

Define FeatureView

driver_hourly_stats_view = FeatureView(
name="driver_hourly_stats",
entities=["driver_id"],
ttl=Duration(seconds=86400 * 1),
features=[
Feature(name="conv_rate", dtype=ValueType.FLOAT),
Feature(name="acc_rate", dtype=ValueType.FLOAT),
Feature(name="avg_daily_trips", dtype=ValueType.INT64),
],
online=True,
batch_source=driver_hourly_stats,
tags={},
)
Feast Apply error stack trace
cdsw@7wp2regwjxlve0wz:~/feature_repo$ feast apply
Traceback (most recent call last):
File "/home/cdsw/.local/bin/feast", line 8, in
sys.exit(cli())
File "/opt/cmladdons/python/site-packages/click/core.py", line 1130, in call
return self.main(*args, **kwargs)
File "/opt/cmladdons/python/site-packages/click/core.py", line 1055, in main
rv = self.invoke(ctx)
File "/opt/cmladdons/python/site-packages/click/core.py", line 1657, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "/opt/cmladdons/python/site-packages/click/core.py", line 1404, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "/opt/cmladdons/python/site-packages/click/core.py", line 760, in invoke
return __callback(*args, **kwargs)
File "/opt/cmladdons/python/site-packages/click/decorators.py", line 26, in new_func
return f(get_current_context(), *args, **kwargs)
File "/home/cdsw/.local/lib/python3.7/site-packages/feast/cli.py", line 489, in apply_total_command
apply_total(repo_config, repo, skip_source_validation)
File "/home/cdsw/.local/lib/python3.7/site-packages/feast/usage.py", line 280, in wrapper
raise exc.with_traceback(traceback)
File "/home/cdsw/.local/lib/python3.7/site-packages/feast/usage.py", line 269, in wrapper
return func(*args, **kwargs)
File "/home/cdsw/.local/lib/python3.7/site-packages/feast/repo_operations.py", line 275, in apply_total
project, registry, repo, store = _prepare_registry_and_repo(repo_config,repo_path)
File "/home/cdsw/.local/lib/python3.7/site-packages/feast/repo_operations.py", line 183, in _prepare_registry_and_repo
repo = parse_repo(repo_path)
File "/home/cdsw/.local/lib/python3.7/site-packages/feast/repo_operations.py", line 116, in parse_repo
module = importlib.import_module(module_path)
File "/usr/local/lib/python3.7/importlib/init.py", line 127, in import_module
return _bootstrap._gcd_import(name[level:], package, level)
File "", line 1006, in _gcd_import
File "", line 983, in _find_and_load
File "", line 967, in _find_and_load_unlocked
File "", line 677, in _load_unlocked
File "", line 728, in exec_module
File "", line 219, in _call_with_frames_removed
File "/home/cdsw/feature_repo/example.py", line 28, in
driver_hourly_stats = HiveSource(table=None,query=my_query,event_timestamp_column="event_timestamp",created_timestamp_column="created",field_mapping=None,date_partition_column="",)
File "/home/cdsw/.local/lib/python3.7/site-packages/feast_hive/hive_source.py", line 98, in init
date_partition_column,
TypeError: init() takes 1 positional argument but 5 were given

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant