Changeset View
Changeset View
Standalone View
Standalone View
python_modules/dagster/dagster/core/definitions/job.py
from enum import Enum | from enum import Enum | ||||
from dagster import check | from dagster import check | ||||
from dagster.core.instance import DagsterInstance | from dagster.core.instance import DagsterInstance | ||||
from dagster.serdes import whitelist_for_serdes | from dagster.serdes import whitelist_for_serdes | ||||
from .mode import DEFAULT_MODE_NAME | from .mode import DEFAULT_MODE_NAME | ||||
from .utils import check_valid_name | from .utils import check_valid_name | ||||
@whitelist_for_serdes | @whitelist_for_serdes | ||||
class JobType(Enum): | class JobType(Enum): | ||||
SCHEDULE = "SCHEDULE" | SCHEDULE = "SCHEDULE" | ||||
SENSOR = "SENSOR" | |||||
class JobContext(object): | class JobContext(object): | ||||
"""Context for generating the execution parameters for an JobDefinition at runtime. | """Context for generating the execution parameters for an JobDefinition at runtime. | ||||
An instance of this class is made available as the first argument to the JobDefinition | An instance of this class is made available as the first argument to the JobDefinition | ||||
functions: run_config_fn, tags_fn | functions: run_config_fn, tags_fn | ||||
▲ Show 20 Lines • Show All 66 Lines • Show Last 20 Lines |