flytekit.ExecutionParameters

class flytekit.ExecutionParameters(execution_date, tmp_dir, stats, execution_id, logging, **kwargs)[source]

This is the context object that is accessible to every @task method. It can be accessed using

flytekit.current_context()
__init__(execution_date, tmp_dir, stats, execution_id, logging, **kwargs)[source]
Parameters
  • execution_date – Date when the execution is running

  • tmp_dir – temporary directory for the execution

  • stats – handle to emit stats

  • execution_id – Identifier for the xecution

  • logging – handle to logging

Methods

__init__(execution_date, tmp_dir, stats, …)

param execution_date

Date when the execution is running

builder()

get(key)

Returns task specific context if present else raise an error.

has_attr(attr_name)

new_builder([current])

Attributes

execution_date

This is a datetime representing the time at which a workflow was started.

execution_id

This is the identifier of the workflow execution within the underlying engine.

logging

A handle to a useful logging object.

secrets

stats

A handle to a special statsd object that provides usefully tagged stats.

working_directory

A handle to a special working directory for easily producing temporary files.