rialto package

Subpackages

• rialto.common package
  • Submodules
  • rialto.common.env_yaml module
    • EnvLoader
      • EnvLoader.yaml_constructors
      • EnvLoader.yaml_implicit_resolvers
  • rialto.common.table_reader module
    • DataReader
      • DataReader.get_latest()
      • DataReader.get_table()
      • DataReader.table_exists()
    • TableReader
      • TableReader.get_latest()
      • TableReader.get_table()
      • TableReader.table_exists()
  • rialto.common.utils module
    • cast_decimals_to_floats()
    • get_caller_module()
    • load_yaml()
  • Module contents
• rialto.jobs package
  • Submodules
  • rialto.jobs.decorators module
    • config_parser()
    • datasource()
    • job()
  • rialto.jobs.job_base module
    • JobBase
      • JobBase.get_custom_callable()
      • JobBase.get_disable_version()
      • JobBase.get_job_metadata()
      • JobBase.get_job_name()
      • JobBase.run()
  • rialto.jobs.module_register module
    • ModuleRegister
      • ModuleRegister.add_callable_to_module()
      • ModuleRegister.find_callable()
      • ModuleRegister.register_callable()
      • ModuleRegister.register_dependency()
      • ModuleRegister.remove_module()
    • register_dependency_callable()
    • register_dependency_module()
  • rialto.jobs.resolver module
    • Resolver
      • Resolver.register_getter()
      • Resolver.register_object()
      • Resolver.resolve()
    • ResolverException
  • rialto.jobs.test_utils module
    • disable_job_decorators()
  • Module contents
• rialto.loader package
  • Submodules
  • rialto.loader.config_loader module
    • get_feature_config()
  • rialto.loader.interfaces module
    • FeatureLoaderInterface
      • FeatureLoaderInterface.get_feature()
      • FeatureLoaderInterface.get_feature_metadata()
      • FeatureLoaderInterface.get_features_from_cfg()
      • FeatureLoaderInterface.get_group()
      • FeatureLoaderInterface.get_group_metadata()
      • FeatureLoaderInterface.get_metadata_from_cfg()
  • rialto.loader.pyspark_feature_loader module
    • PysparkFeatureLoader
      • PysparkFeatureLoader.KeyMap
      • PysparkFeatureLoader.fetch_schema_tables()
      • PysparkFeatureLoader.get_feature()
      • PysparkFeatureLoader.get_feature_metadata()
      • PysparkFeatureLoader.get_features_from_cfg()
      • PysparkFeatureLoader.get_group()
      • PysparkFeatureLoader.get_group_fs_name()
      • PysparkFeatureLoader.get_group_metadata()
      • PysparkFeatureLoader.get_metadata_from_cfg()
      • PysparkFeatureLoader.read_group()
  • Module contents
• rialto.maker package
  • Submodules
  • rialto.maker.containers module
    • FeatureFunction
      • FeatureFunction.get_feature_name()
      • FeatureFunction.get_type()
      • FeatureFunction.metadata()
    • FeatureHolder
      • FeatureHolder.get_metadata()
  • rialto.maker.feature_maker module
  • rialto.maker.utils module
    • feature_name()
  • rialto.maker.wrappers module
    • depends()
    • desc()
    • feature()
    • param()
  • Module contents
• rialto.metadata package
  • Subpackages
    • rialto.metadata.data_classes package
      • Submodules
      • rialto.metadata.data_classes.feature_metadata module
      • rialto.metadata.data_classes.group_metadata module
      • Module contents
  • Submodules
  • rialto.metadata.enums module
    • Schedule
      • Schedule.daily
      • Schedule.monthly
      • Schedule.unscheduled
      • Schedule.weekly
      • Schedule.yearly
    • ValueType
      • ValueType.nominal
      • ValueType.numerical
      • ValueType.ordinal
  • rialto.metadata.metadata_manager module
    • MetadataManager
      • MetadataManager.get_feature()
      • MetadataManager.get_group()
      • MetadataManager.update()
  • rialto.metadata.utils module
    • class_to_catalog_name()
  • Module contents
• rialto.runner package
  • Subpackages
    • rialto.runner.reporting package
      • Submodules
      • rialto.runner.reporting.bookkeeper module
      • rialto.runner.reporting.mailer module
      • rialto.runner.reporting.record module
      • rialto.runner.reporting.tracker module
      • Module contents
    • rialto.runner.services package
      • Submodules
      • rialto.runner.services.config_loader module
      • rialto.runner.services.config_overrides module
      • rialto.runner.services.data_checker module
      • rialto.runner.services.date_manager module
      • rialto.runner.services.executor module
      • rialto.runner.services.result_mapper module
      • rialto.runner.services.table module
      • rialto.runner.services.task_registry module
      • rialto.runner.services.task_status_checker module
      • rialto.runner.services.writer module
      • Module contents
  • Submodules
  • rialto.runner.engine module
    • RunnerEngine
      • RunnerEngine.check_tasks()
      • RunnerEngine.debug_first_task()
      • RunnerEngine.dry_run_execution()
      • RunnerEngine.finalize()
      • RunnerEngine.log_task_status()
      • RunnerEngine.register_tasks()
      • RunnerEngine.run()
      • RunnerEngine.run_tasks()
      • RunnerEngine.select_pipelines()
  • rialto.runner.runner module
    • Runner
      • Runner.dry_run()
  • rialto.runner.runner_services module
    • DefaultRunnerServices
      • DefaultRunnerServices.build()
    • RunnerServices
      • RunnerServices.config
      • RunnerServices.data_checker
      • RunnerServices.date_manager
      • RunnerServices.executor
      • RunnerServices.registry
      • RunnerServices.task_checker
      • RunnerServices.tracker
      • RunnerServices.writer
  • rialto.runner.transformation module
    • Transformation
      • Transformation.run()
  • rialto.runner.utils module
    • find_dependency()
  • Module contents

Module contents