caioau
06/27/2022, 1:19 PMBernhard Stadlbauer
06/27/2022, 1:26 PMistio
over here and we've chosen setup our namespace such that the sidecar does not get injected. You should be able to check if injection is enabled using:
kubectl get namespace -L istio-injection
You could also add the <http://sidecar.istio.io/inject|sidecar.istio.io/inject>: "false"
annotation by default to the pod by adding it to the configmap.k8s.plugins.k8s.default-annotations
config value.
Also of this only works assuming that you don't need the sidecar as part of the pod's work of course.Ketan (kumare3)
caioau
06/27/2022, 3:09 PMKetan (kumare3)
caioau
06/29/2022, 1:29 PM```import typing
import pandas as pd
import numpy as np
from flytekitplugins.pod import Pod
from kubernetes.client.models import V1Container, V1PodSpec
from flytekit import task, workflow
def generate_pod_spec_for_task():
# Primary containers do not require us to specify an image, the default image built for Flyte tasks will get used.
primary_container = V1Container(name="primary")
pod_spec = V1PodSpec(containers=[primary_container])
return pod_spec
@task(task_config=Pod(pod_spec=generate_pod_spec_for_task(), primary_container_name="primary"))
def generate_normal_df(n: int, mean: float, sigma: float) -> pd.DataFrame:
return pd.DataFrame({"numbers": np.random.normal(mean, sigma, size=n)})
@task(task_config=Pod(pod_spec=generate_pod_spec_for_task(), primary_container_name="primary"))
def compute_stats(df: pd.DataFrame) -> typing.Tuple[float, float]:
return float(df["numbers"].mean()), float(df["numbers"].std())
@workflow
def wf(n: int = 200, mean: float = 0.0, sigma: float = 1.0) -> typing.Tuple[float, float]:
return compute_stats(df=generate_normal_df(n=n, mean=mean, sigma=sigma))```
Ketan (kumare3)
caioau
06/29/2022, 9:33 PMKetan (kumare3)