Skip to content

Instantly share code, notes, and snippets.

from featurestore import open_featurestore
from featurestore.domain.featurestores import FeaturestoreReference
# https://flyte.labs.pachama.com/console/projects/baseline/domains/development/executions/fc1hfynprlwrkk-n5-0?duration=all
dev_featurestore = open_featurestore(
FeaturestoreReference(
collection="gs://labs-featurestore/managed/9a873487-91e5-4e83-a965-f737de4ec2c6",
group="group",
)
)
### version information
```
pre-commit version: 2.19.0
git --version: git version 2.30.2
sys.version:
3.9.2 (default, Feb 28 2021, 17:03:44)
[GCC 10.2.1 20210110]
sys.executable: /usr/bin/python3
os.name: posix
File "/home/sabrinalui/pachama/protocol-baseline/baseline/uncertainty/sampling/representative_circles.py", line 123, in __init__
self.aoi_band_stats = compute_zonal_stats(
File "/home/sabrinalui/pachama/protocol-baseline/baseline/zonal_stats.py", line 133, in compute_zonal_stats
clipped = clip_xarray(dset, geo, bands[0], drop=True)
File "/home/sabrinalui/pachama/protocol-baseline/baseline/utils.py", line 576, in clip_xarray
clipped = clipped.where(array_mask)
File "/home/sabrinalui/miniforge3/envs/baseline-dev/lib/python3.10/site-packages/xarray/core/common.py", line 1148, in where
return ops.where_method(self, cond, other)
File "/home/sabrinalui/miniforge3/envs/baseline-dev/lib/python3.10/site-packages/xarray/core/ops.py", line 179, in where_method
return apply_ufunc(
from typing import List
from flytekit import map_task, task, workflow
@task
def my_task(should_succeed: bool) -> bool:
if should_succeed:
return should_succeed
raise ValueError("This is a failure")
[3/3] currentAttempt done. Last Error: SYSTEM::Traceback (most recent call last):
File "/root/micromamba/envs/baseline-dev/lib/python3.10/site-packages/flytekit/exceptions/scopes.py", line 165, in system_entry_point
return wrapped(*args, **kwargs)
File "/root/micromamba/envs/baseline-dev/lib/python3.10/site-packages/flytekit/core/base_task.py", line 518, in dispatch_execute
native_inputs = TypeEngine.literal_map_to_kwargs(exec_ctx, input_literal_map, self.python_interface.inputs)
File "/root/micromamba/envs/baseline-dev/lib/python3.10/site-packages/flytekit/core/type_engine.py", line 868, in literal_map_to_kwargs
return {k: TypeEngine.to_python_value(ctx, lm.literals[k], python_types[k]) for k, v in lm.literals.items()}
File "/root/micromamba/envs/baseline-dev/lib/python3.10/site-packages/flytekit/core/type_engine.py", line 868, in <dictcomp>
return {k: TypeEngine.to_python_value(ctx, lm.literals[k], python_types[k]) for k, v in lm.literals.items()}
[3/3] currentAttempt done. Last Error: SYSTEM::Traceback (most recent call last):
File "/root/micromamba/envs/baseline-dev/lib/python3.10/site-packages/flytekit/exceptions/scopes.py", line 165, in system_entry_point
return wrapped(*args, **kwargs)
File "/root/micromamba/envs/baseline-dev/lib/python3.10/site-packages/flytekit/core/base_task.py", line 518, in dispatch_execute
native_inputs = TypeEngine.literal_map_to_kwargs(exec_ctx, input_literal_map, self.python_interface.inputs)
File "/root/micromamba/envs/baseline-dev/lib/python3.10/site-packages/flytekit/core/type_engine.py", line 868, in literal_map_to_kwargs
return {k: TypeEngine.to_python_value(ctx, lm.literals[k], python_types[k]) for k, v in lm.literals.items()}
File "/root/micromamba/envs/baseline-dev/lib/python3.10/site-packages/flytekit/core/type_engine.py", line 868, in <dictcomp>
return {k: TypeEngine.to_python_value(ctx, lm.literals[k], python_types[k]) for k, v in lm.literals.items()}