MCPcopy Create free account

hub / github.com/Kanegraffiti/Parslet / functions

Functions437 in github.com/Kanegraffiti/Parslet

↓ 1 callersFunctionplot_chart
(data: Dict[str, float] | None, dest: Path)
use_cases/smart_grid_maintenance.py:81
↓ 1 callersMethodpredict
(self, image: Image.Image)
examples/rad_parslet/rad_parslet.py:75
↓ 1 callersFunctionpredict_action
( metrics: Dict[str, float], battery_threshold: float = 40.0 )
use_cases/telecom_power_monitor.py:94
↓ 1 callersFunctionpreprocess_image
( img: Optional[np.ndarray], resources: Dict[str, Optional[float]] )
examples/multi_ai_diagnosis.py:68
↓ 1 callersFunctionprobe_resources
Collect a snapshot of current CPU, RAM and battery metrics.
parslet/utils/resource_utils.py:177
↓ 1 callersFunctionprocess_jobs
(jobs: List[int])
use_cases/shared_hub_jobs.py:66
↓ 1 callersFunctionprocess_light
()
tests/test_variants_selection.py:11
↓ 1 callersFunctionpython_app
Parsl ``python_app`` decorator mapped to :func:`parslet_task`.
parslet/compat/parsl_adapter.py:242
↓ 1 callersFunctionread_logs
(path: str, resources: Dict[str, bool])
use_cases/telecom_power_monitor.py:53
↓ 1 callersMethodrender_epilogue
Return a closing report summarising execution.
parslet/core/concierge.py:79
↓ 1 callersFunctionrun_all
()
run_all_examples.py:78
↓ 1 callersFunctionrun_analysis
Run the RAD analysis on ``image_path``.
examples/rad_pipeline.py:16
↓ 1 callersFunctionrun_example
Load ``module_name`` and execute its ``main()`` function.
run_all_examples.py:27
↓ 1 callersFunctionrun_model
(img: Image.Image | None)
examples/mobile_edge_inference.py:72
↓ 1 callersFunctionrun_rad
(image: str, out_dir: str, ignore_battery: bool = False)
examples/rad_parslet/rad_dag.py:10
↓ 1 callersFunctionsanitize_filenames
(files: List[Path] | None)
use_cases/offline_edu_content_builder.py:61
↓ 1 callersFunctionsave
(img: Image.Image, out: str)
examples/photo_enhancer/workflow.py:27
↓ 1 callersFunctionsave
(rows, labels, out_dir: str)
examples/csv_clean_classify/workflow.py:21
↓ 1 callersFunctionsave_annotated_image
( original: Optional[np.ndarray], edges: Optional[np.ndarray], out_dir: Path, resources: Dict[
examples/multi_ai_diagnosis.py:80
↓ 1 callersFunctionsave_image
Saves a Pillow Image object to the specified path.
examples/image_filter.py:51
↓ 1 callersMethodsave_png
Saves a PNG visualization of the DAG to the specified filepath. This method uses the `save_dag_to_png` utility from the exporter
parslet/core/dag.py:378
↓ 1 callersFunctionsave_report
( result: Dict[str, object], chart: str | None, out_dir: Path, resources: Dict[str, bool], )
use_cases/smart_grid_maintenance.py:99
↓ 1 callersFunctionsave_report
( metrics: Dict[str, float], prediction: Dict[str, str], out_dir: Path, resources: Dict[str, b
use_cases/telecom_power_monitor.py:106
↓ 1 callersFunctionsave_result
( result: Dict[str, object], out_dir: Path, resources: Dict[str, bool] )
examples/mobile_edge_inference.py:104
↓ 1 callersFunctionsave_results
( results: List[int], dest: Path, resources: Dict[str, bool] )
use_cases/shared_hub_jobs.py:71
↓ 1 callersFunctionsave_results
( predictions: List[Dict[str, float]], dest: Path, resources: Dict[str, bool] )
use_cases/offline_crop_diagnosis.py:92
↓ 1 callersFunctionsave_results
Save cleaned data and anomaly info.
examples/edge_mcu_sensor_processing.py:88
↓ 1 callersFunctionsave_schedule
( result: Dict[str, float | str], dest: Path, resources: Dict[str, bool] )
use_cases/solar_scheduling.py:81
↓ 1 callersFunctionsave_scores
( scores: List[Dict[str, str | int]], dest: Path, resources: Dict[str, bool] )
use_cases/triage_tool.py:81
↓ 1 callersFunctionscore_forms
(forms: List[Dict[str, str]])
use_cases/triage_tool.py:68
↓ 1 callersMethodsend
(self, *paths: str | Path)
parslet/hybrid/relay.py:18
↓ 1 callersFunctionsh_allow
()
tests/test_security.py:40
↓ 1 callersFunctionsh_block
()
tests/test_security.py:36
↓ 1 callersFunctionshell_guard
Block shell execution if ``allow`` is :data:`False`. The guard temporarily monkey patches :mod:`os` and :mod:`subprocess` helpers so that any
parslet/security/__init__.py:33
↓ 1 callersFunctionslow_double
(x: int)
tests/test_cache.py:15
↓ 1 callersFunctionslow_double
Expensive computation that benefits from caching.
examples/cached_task.py:7
↓ 1 callersFunctionsmooth_data
Simple moving average smoothing.
examples/edge_mcu_sensor_processing.py:68
↓ 1 callersFunctionsum_results
A simple Parslet task that sums two integer results from previous tasks. Simulates some work using `time.sleep()`. Args: res1 (i
examples/hello.py:115
↓ 1 callersMethodsummarise_runner
(runner: "RunnerProtocol")
parslet/core/concierge.py:156
↓ 1 callersFunctiont1
()
tests/test_dag_io.py:5
↓ 1 callersFunctiont1
()
tests/test_dag.py:5
↓ 1 callersFunctiont2
(x: int)
tests/test_dag_io.py:10
↓ 1 callersFunctiont2
(x)
tests/test_dag.py:10
↓ 1 callersMethodtask_priority
(self, fut: ParsletFuture, power: PowerState)
parslet/core/policy.py:47
↓ 1 callersFunctionvalidate_responses
( items: Iterable[Dict[str, str]], )
use_cases/offline_survey_flow.py:79
↓ 1 callersFunctionwork
A tiny task used to demonstrate AdaptivePolicy.
examples/policy_example.py:8
↓ 1 callersFunctionwrapper
(func: Callable)
parslet/compat/dask_adapter.py:222
↓ 1 callersFunctionwrapper
(func)
parslet/compat/parsl_adapter.py:245
↓ 1 callersFunctionwrite_manifest
( file_names: List[str], dest: Path, resources: Dict[str, bool] )
use_cases/offline_edu_content_builder.py:88
↓ 1 callersMethodwrite_runbook
(self, path: str | Path, runner: "RunnerProtocol" | None = None)
parslet/core/concierge.py:132
Method__enter__
(self)
tests/test_network_utils.py:7
Method__exit__
(self, exc_type, exc, tb)
tests/test_network_utils.py:10
Method__getattr__
(self, attr)
parslet/compat/parsl_adapter.py:309
Method__init__
(self)
parslet/compat/dask_adapter.py:24
Method__init__
(self, *args, **kwargs)
parslet/compat/parsl_adapter.py:302
Method__init__
(self, *args: object, **kwargs: object)
parslet/security/__init__.py:60
Method__init__
Create a new manager for ``filepath``. The file is loaded if it already exists so that previously completed task IDs are remembered.
parslet/utils/checkpointing.py:12
Method__init__
(self, destination: str)
parslet/hybrid/relay.py:15
Method__init__
(self, enabled: Iterable[str] | None = None)
parslet/core/context.py:48
Method__init__
Initializes a new ParsletFuture. Args: task_id (str): The unique ID for this task instance. func (Callable[.
parslet/core/task.py:81
Method__init__
( self, battery_mode: bool = False, policy: AdaptivePolicy | None = None )
parslet/core/scheduler.py:20
Method__init__
( self, skipped_task_id: str, skipped_task_name: str, original_failure_task_id
parslet/core/runner.py:63
Method__init__
(self, task_id: str, task_name: str, battery_level: int)
parslet/core/runner.py:91
Method__init__
( self, task_id: str, task_name: str, results: list[ContextResult], )
parslet/core/runner.py:108
Method__init__
(self, dag: DAG, oracle: ContextOracle)
parslet/core/concierge.py:37
Method__init__
( self, message: str = ( "Graphviz executables (like 'dot') not found in system PA
parslet/core/exporter.py:65
Method__init__
Initializes an empty DAG. The graph is stored as a NetworkX DiGraph, and task futures are stored in a dictionary.
parslet/core/dag.py:62
Method__init__
(self, value)
tests/test_parsl_bridge.py:16
Method__init__
(self, executors=None, run_dir=None)
tests/test_parsl_bridge.py:40
Method__init__
(self, label="local")
tests/test_parsl_bridge.py:45
Method__init__
(self, value)
tests/test_hybrid.py:11
Method__init__
(self, executors=None)
tests/test_hybrid.py:35
Method__init__
(self, label="remote")
tests/test_hybrid.py:40
Method__init__
(self, level: int)
examples/rad_parslet/rad_parslet.py:34
Method__repr__
Provides a developer-friendly string representation of the ParsletFuture. Returns: str: A string like "<ParsletF
parslet/core/task.py:121
Method__str__
Returns the detailed error message.
parslet/core/runner.py:83
Function_blocked_socket
(*args: object, **kwargs: object)
parslet/security/__init__.py:88
Method_cb
( executor_fut: ExecutorFuture[Any], parslet_fut: ParsletFutur
parslet/core/runner.py:817
Function_psutil_provider
Return power information using :mod:`psutil` if available.
parslet/utils/power.py:41
Function_run
()
parslet/main_cli.py:239
Function_sysfs_provider
Attempt to gather battery info from ``/sys`` paths.
parslet/utils/power.py:68
Function_termux_provider
Use ``termux-battery-status`` if available on the PATH.
parslet/utils/power.py:90
Method_wrapped_task_execution
Execute a task function and translate resource errors.
parslet/core/runner.py:368
Methodadd_task
(Deprecated or Internal) Adds a single task and its dependencies recursively. Note: This method was part of an earlier graph
parslet/core/dag.py:73
Methodall_tasks_and_dependencies_known
(Utility/Debug) Checks if all futures reachable from `entry_futures` (including transitive dependencies in their args/kwargs) are kno
parslet/core/dag.py:410
Methodavailable_contexts
Return a sorted list of known context names.
parslet/core/context.py:101
Functionbase
()
tests/test_task.py:50
Functionbash_app
Parsl ``bash_app`` decorator executed via :mod:`subprocess`. The decorated function must return a string representing the shell command to ex
parslet/compat/parsl_adapter.py:253
Functioncheck_pr_changes
Defcon 1: basic validation of changed Python files. Rejects files containing `exec` or `os.system` calls. Returns ``True`` if all files are s
parslet/utils/parslet_defcon.py:12
Functionclear
()
tests/test_parsl_bridge.py:55
Functionclear
()
tests/test_hybrid.py:50
Methoddecide_max_workers
Adjust the worker pool based on power level.
parslet/core/policy.py:66
Functiondecorator
(func: Callable[..., Any])
parslet/core/task.py:449
Functiondfk
()
tests/test_parsl_bridge.py:52
Functiondfk
()
tests/test_hybrid.py:47
Methodenable
Manually enable a context tag for the lifetime of the oracle.
parslet/core/context.py:71
Functionexport_dag_to_json
(dag: DAG, path: str)
parslet/core/dag_io.py:23
Functionfake_batt
()
tests/test_scheduler.py:11
Functionfake_batt
()
tests/test_battery_sensitive.py:11
Functionfake_cpu
()
tests/test_scheduler.py:5
← previousnext →201–300 of 437, ranked by callers