MCPcopy Create free account

hub / github.com/ArchieGertsman/spark-sched-sim / functions

Functions248 in github.com/ArchieGertsman/spark-sched-sim

Methodcompleted
(self)
spark_sched_sim/components/stage.py:38
Methodcompleted
(self)
spark_sched_sim/components/job.py:50
Functiondecima_example
()
examples.py:64
Methoddurations
(key)
spark_sched_sim/data_samplers/tpch.py:163
Functionevaluate
scores: scores that the model assigned to each action at each step counts: count of available actions at each step selections: actions th
schedulers/decima/utils.py:26
Methodevaluate_actions
( self, obsns: Iterable[dict], actions: Iterable[tuple] )
schedulers/decima/scheduler.py:101
Functionfair_example
()
examples.py:49
Methodforward
Returns: a dict of representations at three different levels: node, dag, and global.
schedulers/decima/scheduler.py:152
Methodforward
returns a tensor of shape [num_nodes, embed_dim]
schedulers/decima/scheduler.py:191
Methodforward
returns a tensor of shape [num_dags, embed_dim]
schedulers/decima/scheduler.py:252
Methodforward
returns a tensor of shape [num_observations, embed_dim]
schedulers/decima/scheduler.py:265
Methodforward
returns a tensor of shape [num_nodes,]
schedulers/decima/scheduler.py:293
Methodforward
( self, dag_batch: pyg.data.Batch, h_dict: dict[str, Tensor], job_indices: Tensor )
schedulers/decima/scheduler.py:338
Methodget_children_stages
(self, stage: Stage)
spark_sched_sim/components/job.py:75
Methodinfo
(self)
spark_sched_sim/spark_sched_sim.py:240
Methodis_idle
(self)
spark_sched_sim/components/executor.py:28
Functionjob_duration_percentiles
(env)
spark_sched_sim/metrics.py:21
Methodjob_pool_key
(self)
spark_sched_sim/components/stage.py:34
Methodjob_sequence
(self, max_time: float)
spark_sched_sim/data_samplers/data_sampler.py:16
Functionmake_adj
returns a sparse COO adjacency matrix
schedulers/decima/utils.py:67
Functionmake_dag_layer_edge_masks
returns a batch of edge masks of shape (msg passing depth, num edges), where the i'th mask indicates which edges participate in the i'th root-to-l
schedulers/decima/utils.py:238
Functionmake_mlp
( input_dim: int, hid_dims: list[int], output_dim: int, act_cls: str, act_kwargs: dict[str
schedulers/decima/utils.py:45
Methodnext_task_id
(self)
spark_sched_sim/components/stage.py:46
Methodnum_active_jobs
(self)
spark_sched_sim/spark_sched_sim.py:236
Methodnum_active_stages
(self)
spark_sched_sim/components/job.py:62
Methodnum_completed_jobs
(self)
spark_sched_sim/spark_sched_sim.py:232
Methodnum_saturated_tasks
(self)
spark_sched_sim/components/stage.py:42
Methodnum_stages
(self)
spark_sched_sim/components/job.py:58
Functionobs_to_pyg
converts an env observation into a PyG `Batch` object
schedulers/decima/utils.py:88
Methodobservation
(self, obs: dict[str, Any])
schedulers/decima/env_wrapper.py:69
Methodpool_key
(self)
spark_sched_sim/components/stage.py:30
Methodpool_key
(self)
spark_sched_sim/components/job.py:46
Methodreset
( self, seed: int | None = None, options: dict[str, Any] | None = None )
spark_sched_sim/spark_sched_sim.py:127
Methodreset
(self)
spark_sched_sim/components/executor_tracker.py:32
Methodreset
samples a new time limit prior to resetting
spark_sched_sim/wrappers/stochastic_time_limit.py:13
Methodreset
(self, np_random: np.random.Generator)
spark_sched_sim/data_samplers/data_sampler.py:12
Methodreset
(self, np_random: np.random.Generator)
spark_sched_sim/data_samplers/tpch.py:51
Functionsample
(logits: Tensor)
schedulers/decima/utils.py:19
Methodsaturated
(self)
spark_sched_sim/components/job.py:54
Methodschedule
(self, obs: dict)
schedulers/heuristics/round_robin.py:14
Methodschedule
(self, obs: dict)
schedulers/heuristics/random_scheduler.py:16
Methodschedule
(self, obs: dict)
schedulers/decima/scheduler.py:72
Methodstep
modifies `truncated` signal when time limit is reached
spark_sched_sim/wrappers/stochastic_time_limit.py:26
Methodtask_duration
( self, job: Job, stage: Stage, task: Task, executor: Executor )
spark_sched_sim/data_samplers/data_sampler.py:20
Functiontest_train
()
test/test_train.py:5
Methodtrain_on_rollouts
(self, rollout_buffers)
trainers/vpg.py:19
Methodtrain_on_rollouts
(self, rollout_buffers)
trainers/ppo.py:51
Methodwindow
lazy-init the window
spark_sched_sim/components/renderer.py:34
← previous201–248 of 248, ranked by callers