Skip to content

Releases: Netflix/metaflow

2.11.13

06 May 21:57
5e05540
Compare
Choose a tag to compare

Features

Configurable default Kubernetes resources

This release introduces configuration options for setting default values for cpu / memory / disk when running on Kubernetes. These can be set either with environment variables

METAFLOW_KUBERNETES_CPU=
METAFLOW_KUBERNETES_MEMORY=
METAFLOW_KUBERNETES_DISK=

or in a Metaflow profile

{
  "KUBERNETES_CPU": "",
  "KUBERNETES_MEMORY": "",
  "KUBERNETES_DISK": "",
}

These values will be overruled by specifying a value through the @kubernetes or @resources decorators.

Improvements

Support for wider foreach flows with Argo Workflows

This release changes the way task ids are generated on Argo Workflows in order to solve an issue where extremely wide foreach splits could not execute correctly due to hard limits on input parameters size on Argo Workflows.

What's Changed

New Contributors

Full Changelog: 2.11.12...2.11.13

2.11.12

03 May 19:59
9989bc6
Compare
Choose a tag to compare

What's Changed

  • Fix: JSON Reference Path Error in AWS Step Functions Distributed Map by @nidhinnru in #1822
  • fix import of the new escape hatch flag by @wangchy27 in #1823

New Contributors

Full Changelog: 2.11.11...2.11.12

2.11.11

02 May 21:39
302f057
Compare
Choose a tag to compare

What's Changed

New Contributors

Full Changelog: 2.11.10...2.11.11

2.11.10

11 Apr 21:08
5908c4e
Compare
Choose a tag to compare

Improvements

Argo Events trigger improvements for parameters with default values

This release fixes an issue where partial or empty argo event payloads would incorrectly overwrite the default values for the parameters of a triggered flow.

For example a flow with

@trigger(events=["params_event"])
class DefaultParamEventFlow(FlowSpec):

    param_a = Parameter(
        name="param_a",
        default="default value A",
    )

    param_b = Parameter(
        name="param_b",
        default="default value B",
    )

will now correctly have the default values for its parameters when triggered by

from metaflow.integrations import ArgoEvent
ArgoEvent('params_event').publish()

or a default value for param_b and the supplied value for param_a when triggered by

ArgoEvent('params_event').publish({"param_a": "custom-value"})

What's Changed

Full Changelog: 2.11.9...2.11.10

2.11.9

29 Mar 18:23
bae5c10
Compare
Choose a tag to compare

What's Changed

Full Changelog: 2.11.8...2.11.9

2.11.8

29 Mar 10:22
e577781
Compare
Choose a tag to compare

What's Changed

Full Changelog: 2.11.7...2.11.8

2.11.7

27 Mar 21:09
4d855ab
Compare
Choose a tag to compare

What's Changed

Full Changelog: 2.11.6...2.11.7

2.11.6

23 Mar 20:16
Compare
Choose a tag to compare

What's Changed

Full Changelog: 2.11.5...2.11.6

2.11.5

14 Mar 17:27
ef7cb9d
Compare
Choose a tag to compare

What's Changed

New Contributors

Full Changelog: 2.11.4...2.11.5

2.11.4

27 Feb 00:37
c90a71b
Compare
Choose a tag to compare

What's Changed

Full Changelog: 2.11.3...2.11.4