Miha Garafolj
10/10/2022, 2:30 PMTolerations: <http://node.kubernetes.io/not-ready:NoExecute|node.kubernetes.io/not-ready:NoExecute> op=Exists for 300s
<http://node.kubernetes.io/unreachable:NoExecute|node.kubernetes.io/unreachable:NoExecute> op=Exists for 300s
Example tolerations on another pod (also flyte created).
Tolerations: <http://node.kubernetes.io/not-ready:NoExecute|node.kubernetes.io/not-ready:NoExecute> op=Exists for 300s
<http://node.kubernetes.io/unreachable:NoExecute|node.kubernetes.io/unreachable:NoExecute> op=Exists for 300s
<http://nvidia.com/gpu=present:NoSchedule|nvidia.com/gpu=present:NoSchedule>
<http://nvidia.com/gpu:NoSchedule|nvidia.com/gpu:NoSchedule> op=Exists
purpose=compute:NoSchedule
We already tried to restart the node pool. Is this somehow an expected behavior?
Flytekit version: 1.1.0
Frank Shen
10/10/2022, 7:00 PMfrom flytekit import LaunchPlan, current_context, task, workflow
@task
def square(val: int) -> int:
return val * val
@workflow
def my_wf(val: int) -> int:
result = square(val=val)
return result
default_lp = LaunchPlan.get_default_launch_plan(current_context(), my_wf)
square_3 = default_lp(val=3)
seunggs
10/11/2022, 3:23 AM.npy
extension:seunggs
10/11/2022, 3:23 AM{
"o0": {
"type": "single (NumpyArray) blob",
"uri": "<s3://sidetrek-flyte-cluster-flyte-bucket/j7/s8df0ape621iv5k8jz0t-n3-0/5a5182507b2e1d3759ca877860fb780c/5d8c4cacddf4ae178bc3987478b0cb24.npy>"
}
}
seunggs
10/11/2022, 3:25 AMnp.load
after downloading the file, but is there any easier way to retrieve the data?Adwitiya
10/11/2022, 7:14 AMvarsha Parthasarathy
10/11/2022, 1:53 PMKrishna Agarwal
10/12/2022, 10:42 AMChris Hairfield
10/12/2022, 9:26 PMsandbox
environment with --fast
registration, which is pretty awesome. But now I’m stuck trying to set inputs specific to developing in sandbox
(e.g., hostname of an external service running on my local machine).
Question: How do I enable a schedule with specified inputs that override default_inputs
whenever the scheduler invokes my workflow?
What I think I want is a commandline like:
flytectl update launchplan -p {project} -d {domain} {lp_name} --version {version} --activate --execFile exec_spec.yaml
As a test, when I try to follow this line from the docs and omit a required input from the LaunchPlan.get_or_create
call, then my schedule simply doesn’t run when actived:
Launch plans do not necessarily contain the entire set of required workflow inputs
I hope I’m just missing something! Thanks.SeungTaeKim
10/13/2022, 1:37 AMKS Tarun
10/13/2022, 5:24 AMkubectl get pods -n flyte
, the output is as shown below:
NAME READY STATUS RESTARTS AGE
flyte-deps-contour-contour-cd4d956d9-2xlwk 1/1 Running 0 19d
flyte-deps-contour-envoy-244xb 2/2 Running 0 19d
flyte-deps-contour-envoy-rbwp7 2/2 Running 0 19d
flyte-deps-kubernetes-dashboard-8b7d858b7-x9ncd 1/1 Running 0 19d
flyte-pod-webhook-85ff4b5f9d-t9l2f 1/1 Running 0 19d
flyteadmin-b46f578c7-qww88 1/1 Running 0 17d
flyteconsole-77f665cc84-8gmv7 1/1 Running 0 19d
flytepropeller-655664f9f9-6c69v 1/1 Running 0 14d
flytepropeller-655664f9f9-l67tf 0/1 Error 0 14d
flytepropeller-655664f9f9-zz2c2 0/1 Error 0 19d
flytescheduler-6db897d545-mlntd 0/1 ContainerStatusUnknown 1 14d
flytescheduler-6db897d545-mmhtl 1/1 Running 563 (8m45s ago) 10d
minio-5cbbccf6cd-bm6ms 1/1 Running 0 17d
postgres-565f59484-qcnjq 1/1 Running 0 19d
syncresources-7b4b44f7cc-p4h9j 1/1 Running 0 19d
But when we run any command to run/register a workflow pyflyte run ........ etc.
, we're getting the below error:
Traceback (most recent call last):
File "/home/tarun/.local/bin/pyflyte", line 5, in <module>
from flytekit.clis.sdk_in_container.pyflyte import main
File "/home/tarun/.local/lib/python3.8/site-packages/flytekit/__init__.py", line 259, in <module>
load_implicit_plugins()
File "/home/tarun/.local/lib/python3.8/site-packages/flytekit/__init__.py", line 253, in load_implicit_plugins
discovered_plugins = entry_points(group="flytekit.plugins")
TypeError: entry_points() got an unexpected keyword argument 'group'
Can someone explain, what might be the cause of this error ?Yash Panchwatkar
10/13/2022, 11:43 AMYash Panchwatkar
10/13/2022, 12:21 PMYash Panchwatkar
10/13/2022, 1:30 PMSanjay Chouhan
10/13/2022, 4:32 PMYee
10/13/2022, 5:22 PMChandramoulee K V
10/14/2022, 5:39 AMcontainers with unready status: [a4tbv4qblclb2d8kdqg6-n1-0]|Back-off pulling image {ECR IMAGE}
What all accesses should be provided to the ECR image? Any idea on thisJun Kwan
10/14/2022, 11:34 AMfinal_img = Image.merge(
"YCbCr",
[
img_out_y,
img_cb.resize(img_out_y.size, Image.BICUBIC),
img_cr.resize(img_out_y.size, Image.BICUBIC),
],
).convert("RGB")
img_path = (
Path("cat_superres_with_ort.jpg")
)
final_img.save(img_path)
Where can I find cat_superres_with_ort.jpg? Thanks!Sanjay Chouhan
10/14/2022, 1:43 PMSky Wolf
10/15/2022, 2:50 AMSky Wolf
10/15/2022, 2:51 AMYash Panchwatkar
10/15/2022, 6:47 AMYash Panchwatkar
10/15/2022, 6:51 AMYash Panchwatkar
10/15/2022, 6:53 AMYash Panchwatkar
10/15/2022, 6:57 AMYash Panchwatkar
10/15/2022, 7:20 AMYash Panchwatkar
10/15/2022, 7:21 AMYash Panchwatkar
10/15/2022, 7:28 AMYash Panchwatkar
10/15/2022, 7:28 AMThusal Ranawaka
10/15/2022, 10:53 AMThusal Ranawaka
10/15/2022, 10:53 AM