• Zachary Carrico

    Zachary Carrico

    2 months ago
    Hi! I’m trying to add a kubernetes pod label to all pods generated as a result of launching a workflow. Execution code:
    remote.execute(
            workflow,
            inputs=inputs,
            options=Options(labels=common_models.Labels({"flyte.user": os.getenv("USER", "na")}))
    where
    remote
    is of type
    FlyteRemote
    . I can see that the workflow’s pod has the expected label, but none of the subworkflows do. Is there a way to have all pod labels be passed to all child pods of a workflow pod?
    Zachary Carrico
    Dan Rammer (hamersaw)
    +1
    11 replies
    Copy to Clipboard
  • Dylan Wilder

    Dylan Wilder

    2 months ago
    has there been any consideration to caching at the lp/workflow level?
    Dylan Wilder
    Yee
    +1
    3 replies
    Copy to Clipboard
  • Rahul Mehta

    Rahul Mehta

    1 month ago
    Is it possible to mix
    @flytekit.dynamic
    &
    with_overrides
    ? Curious if we could pass a resource configuration object to a workflow at runtime and have the
    @dynamic
    step specify overrides at runtime
    Rahul Mehta
    Ketan (kumare3)
    +2
    23 replies
    Copy to Clipboard
  • Dylan Wilder

    Dylan Wilder

    1 month ago
    anyone else use flytectl with M1 chips? getting a segfault when running
    Dylan Wilder
    Ketan (kumare3)
    +6
    35 replies
    Copy to Clipboard
  • Ketan (kumare3)

    Ketan (kumare3)

    1 month ago
    Cc @Kevin Su / @Yee - the protocol part - https://github.com/flyteorg/flytekit/pull/1116 - is that right? Can we talk and change it? @Evan Sadler
  • Dylan Wilder

    Dylan Wilder

    1 month ago
    Upgrading to flytekit 1.0 and i have a task taking a single schema which can't marshal it to a dataframe because this conditional is false
    lv and lv.scalar and lv.scalar.schema
    . looking at the inputs it seems that old versions of the task don't have the
    format
    field in the flyte literal, but now they do. also looks like this code returns empty dataframe rather than erroring. any context on these changes that might help point to the behavior we're seeing?
    Dylan Wilder
    Ketan (kumare3)
    +1
    32 replies
    Copy to Clipboard
  • Dylan Wilder

    Dylan Wilder

    1 month ago
    side question from the above, a structured datasets and flyteschemas interoperable at all
    Dylan Wilder
    Yee
    4 replies
    Copy to Clipboard
  • Dylan Wilder

    Dylan Wilder

    1 month ago
    more flytekit 1.0 questions: is there a way to set default resource settings? we used to use flyte-cli with the flyte conf file but that's no longer used
    Dylan Wilder
    Yee
    10 replies
    Copy to Clipboard
  • Dylan Wilder

    Dylan Wilder

    1 month ago
    this seems potentially really cool, but i don't see an explainer in the docs. what does this do?
    Annotated[StructuredDataset, subset_cols]
    Dylan Wilder
    Yee
    11 replies
    Copy to Clipboard