API

The page contains the API documentation for the malevich package. Explore available interfaces and classes by following the links below.

Submodules prefixed with an underscore are not intended for direct use. They are either imported into the main namespace or used internally by other modules.

• Assistants
  • Core
  • Space
• malevich._autoflow
  • autotrace()
  • sinktrace()
  • Flow
    • Flow.isinflow()
    • Flow.flow_ref()
    • Flow.get_stack()
  • root
    • root.model_computed_fields
    • root.model_config
    • root.model_fields
  • autoflow
    • autoflow.attach()
    • autoflow.calledby()
  • traced
    • traced.claim()
  • tracedLike
    • tracedLike.claim()
  • BadEdgeError
  • ExecutionTree
    • ExecutionTree.put_edge()
    • ExecutionTree.prune()
    • ExecutionTree.edges_from()
    • ExecutionTree.traverse()
    • ExecutionTree.leaves()
    • ExecutionTree.connected()
    • ExecutionTree.nodes()
• malevich._meta
  • AssetFactory
    • AssetFactory.on_core()
    • AssetFactory.on_space()
    • AssetFactory.from_file()
    • AssetFactory.from_files()
  • config()
  • flow()
  • run()
  • table
• malevich.interpreter
  • malevich.interpeter.core
    • CoreInterpreter
  • malevich.interpeter.space
    • SpaceInterpreter
• malevich.models
  • FlowFunction
    • FlowFunction.__init__()
  • ComponentSchema
  • PromisedStage
  • PromisedTask
    • PromisedTask.tree
    • PromisedTask.get_stage()
    • PromisedTask.get_stage_class()
    • PromisedTask.interpret()
    • PromisedTask.prepare()
    • PromisedTask.async_prepare()
    • PromisedTask.async_run()
    • PromisedTask.async_stop()
    • PromisedTask.run()
    • PromisedTask.stop()
    • PromisedTask.results()
    • PromisedTask.commit_returned()
    • PromisedTask.dump()
    • PromisedTask.load()
    • PromisedTask.get_injectables()
    • PromisedTask.get_operations()
    • PromisedTask.configure()
    • PromisedTask.get_interpreted_task()
    • PromisedTask.publish()
  • BaseResult
    • BaseResult.num_elements
    • BaseResult.get()
    • BaseResult.get_df()
    • BaseResult.get_dfs()
    • BaseResult.get_binary()
    • BaseResult.get_binary_dir()
  • CoreLocalDFResult
    • CoreLocalDFResult.num_elements()
    • CoreLocalDFResult.get()
  • CoreResult
    • CoreResult.num_elements
    • CoreResult.get()
    • CoreResult.get_df()
    • CoreResult.get_dfs()
    • CoreResult.get_binary()
    • CoreResult.get_binary_dir()
  • CoreResultPayload
    • CoreResultPayload.is_asset()
    • CoreResultPayload.is_composite_asset()
    • CoreResultPayload.is_collection()
  • SpaceCollectionResult
    • SpaceCollectionResult.num_elements()
    • SpaceCollectionResult.get()
    • SpaceCollectionResult.get_dfs()
    • SpaceCollectionResult.get_df()
  • ArgumentLink
• malevich.square
  • malevich.square.jls
    • processor()
    • scheme()
    • init()
  • malevich.square.utils
    • Context
      • Context.app_id
      • Context.run_id
      • Context.dag_key_value
      • Context.object_storage
      • Context.common
      • Context.share()
      • Context.async_share()
      • Context.share_many()
      • Context.async_share_many()
      • Context.get_share_path()
      • Context.delete_share()
      • Context.async_delete_share()
      • Context.synchronize()
      • Context.async_synchronize()
      • Context.msg()
      • Context.async_msg()
      • Context.email_send()
      • Context.metadata()
      • Context.scale_info
      • Context.get_scale_part()
      • Context.operation_id
      • Context.has_object()
      • Context.get_object()
      • Context.as_object()
      • Context._ObjectStorage
      • Context._DagKeyValue
    • S3Helper
      • S3Helper.create_by_cfg()
      • S3Helper.get_object()
      • S3Helper.get_df()
      • S3Helper.save_object()
      • S3Helper.save_df()
      • S3Helper.delete_object()
    • SmtpSender
      • SmtpSender.send()
    • to_df()
    • from_df()
    • to_binary()
    • from_binary()
    • APP_DIR
    • WORKDIR
  • malevich.square.df
    • DF
      • DF.scheme_name()
    • DFS
      • DFS.__getitem__()
      • DFS.__iter__()
      • DFS.__len__()
    • OBJ
      • OBJ.path
      • OBJ.raw
      • OBJ.as_df
      • OBJ.df
    • M
    • Sink