MCPcopy Create free account

hub / github.com/Kanegraffiti/Parslet / functions

Functions437 in github.com/Kanegraffiti/Parslet

⨍ Functions 437◇ Types & classes 46
↓ 1 callersFunctioncheck_resources
( min_ram_mb: int = 100, min_battery: int = 20 )
use_cases/smart_grid_maintenance.py:35
↓ 1 callersFunctioncheck_resources
( min_ram_mb: int = 50, min_battery: int = 20 )
use_cases/telecom_power_monitor.py:36
↓ 1 callersFunctioncheck_resources
( min_ram_mb: int = 40, min_battery: int = 20 )
use_cases/solar_scheduling.py:34
↓ 1 callersFunctioncheck_resources
( min_ram_mb: int = 20, min_battery: int = 10 )
use_cases/triage_tool.py:33
↓ 1 callersFunctioncheck_resources
( min_ram_mb: int = 50, min_battery: int = 20 )
use_cases/offline_crop_diagnosis.py:35
↓ 1 callersFunctioncheck_resources
( min_ram_mb: int = 30, min_battery: int = 15 )
use_cases/offline_survey_flow.py:35
↓ 1 callersFunctioncheck_resources
Check available RAM and battery level.
examples/edge_mcu_sensor_processing.py:37
↓ 1 callersFunctioncheck_resources
Return resource info and whether it's safe to proceed.
examples/multi_ai_diagnosis.py:37
↓ 1 callersFunctioncheck_resources
( min_ram_mb: int = 100, min_battery: int = 20 )
examples/mobile_edge_inference.py:44
↓ 1 callersFunctionclassify
(rows)
examples/csv_clean_classify/workflow.py:16
↓ 1 callersFunctionclassify_images
(paths: List[Path] | None)
use_cases/offline_crop_diagnosis.py:70
↓ 1 callersMethodcleanup
(self)
tests/test_parsl_bridge.py:49
↓ 1 callersFunctioncli
Parse command line arguments and dispatch the chosen command.
parslet/main_cli.py:18
↓ 1 callersFunctioncompute_cache_key
Compute a deterministic hash for a task invocation. Parameters ---------- task_name: Registered name of the task. args:
parslet/core/cache.py:33
↓ 1 callersFunctionconvert_dask_to_parslet
Convert Dask-based code string to Parslet syntax.
parslet/compat/dask_adapter.py:84
↓ 1 callersFunctionconvert_grayscale
Converts a Pillow Image object to grayscale.
examples/image_filter.py:22
↓ 1 callersFunctionconvert_parsl_to_parslet
Convert Parsl-based code string to Parslet syntax.
parslet/compat/parsl_adapter.py:63
↓ 1 callersFunctionconvert_parslet_to_parsl
Convert Parslet-based code string to Parsl syntax.
parslet/compat/parsl_adapter.py:86
↓ 1 callersFunctioncopy_files
(files: List[Path] | None, dest: Path)
use_cases/offline_edu_content_builder.py:72
↓ 1 callersFunctioncount_frames
(frames: List[Path])
examples/video_frames.py:42
↓ 1 callersFunctioncreate_output_dir
(base: str | None = None)
use_cases/offline_edu_content_builder.py:26
↓ 1 callersFunctioncreate_output_dir
(base: str | None = None)
use_cases/shared_hub_jobs.py:24
↓ 1 callersFunctioncreate_output_dir
(base: str | None = None)
use_cases/smart_grid_maintenance.py:26
↓ 1 callersFunctioncreate_output_dir
(base: str | None = None)
use_cases/telecom_power_monitor.py:27
↓ 1 callersFunctioncreate_output_dir
(base: str | None = None)
use_cases/solar_scheduling.py:25
↓ 1 callersFunctioncreate_output_dir
(base: str | None = None)
use_cases/triage_tool.py:24
↓ 1 callersFunctioncreate_output_dir
(base: str | None = None)
use_cases/offline_crop_diagnosis.py:26
↓ 1 callersFunctioncreate_output_dir
(base: str | None = None)
use_cases/offline_survey_flow.py:26
↓ 1 callersFunctioncreate_output_dir
Create a timestamped results directory.
examples/edge_mcu_sensor_processing.py:27
↓ 1 callersFunctioncreate_output_dir
Create timestamped result directory.
examples/multi_ai_diagnosis.py:25
↓ 1 callersFunctioncreate_output_dir
(base: str | None = None)
examples/mobile_edge_inference.py:35
↓ 1 callersFunctiondag_to_dot_string
Generates a DOT language string representation of the Parslet DAG. The DOT language is a plain text graph description language. This string
parslet/core/exporter.py:126
↓ 1 callersFunctiondecorator
(func)
parslet/compat/parsl_adapter.py:266
↓ 1 callersFunctiondecorator_parslet_task
( func_to_wrap: Callable[..., Any], )
parslet/core/task.py:305
↓ 1 callersFunctiondelay_if_low
(threshold: int = 20)
examples/photo_enhancer/workflow.py:9
↓ 1 callersFunctiondelayed
Dask ``delayed`` decorator mapped to :func:`parslet_task`.
parslet/compat/dask_adapter.py:219
↓ 1 callersFunctiondetect_anomalies
Return indices where a spike/drop occurs.
examples/edge_mcu_sensor_processing.py:78
↓ 1 callersFunctionecho_message
(msg)
tests/test_parsl_adapter_runtime.py:60
↓ 1 callersFunctionenhance
(img: Image.Image)
examples/photo_enhancer/workflow.py:22
↓ 1 callersFunctionensure_sample_video
Ensure a small sample.mp4 video exists and return its path.
examples/utils.py:22
↓ 1 callersFunctionevaluate
( data: Dict[str, float] | None, threshold: float = 80.0 )
use_cases/smart_grid_maintenance.py:71
↓ 1 callersFunctionex_task_a
()
parslet/core/exporter.py:256
↓ 1 callersFunctionex_task_b
(dep_a)
parslet/core/exporter.py:260
↓ 1 callersFunctionex_task_c
(dep_b)
parslet/core/exporter.py:264
↓ 1 callersFunctionexecute_hybrid
Execute a workflow mixing local and Parsl-backed tasks. Tasks are automatically routed to the remote Parsl backend when they are defined with
parslet/hybrid/executor.py:16
↓ 1 callersFunctionexecute_with_parsl
Execute a Parslet workflow using Parsl's runtime. ``entry_futures`` should be the same list returned by your workflow's ``main()`` function.
parslet/core/parsl_bridge.py:72
↓ 1 callersFunctionexpensive
()
tests/test_energy_policy_ordering.py:7
↓ 1 callersFunctionexport_dask_dag
Export a Parslet DAG to a Dask-style Python script.
parslet/compat/dask_adapter.py:169
↓ 1 callersFunctionextract_frames
Save all frames from ``video_path`` to ``out_dir``.
examples/video_frames.py:20
↓ 1 callersFunctionfail
()
tests/test_parsl_adapter_runtime.py:71
↓ 1 callersFunctionfinalize_results
( res_a: Dict[str, Optional[float]], res_b: Dict[str, Optional[float]], resources: Dict[str, Optio
examples/multi_ai_diagnosis.py:176
↓ 1 callersFunctionflaky
()
tests/test_retries.py:8
↓ 1 callersFunctionfragile
()
tests/test_failsafe_mode.py:5
↓ 1 callersFunctiongather_files
(src: str, resources: Dict[str, bool])
use_cases/offline_edu_content_builder.py:52
↓ 1 callersFunctiongather_images
( folder: str, resources: Dict[str, bool] )
use_cases/offline_crop_diagnosis.py:52
↓ 1 callersFunctiongenerate_schedule
(values: List[float])
use_cases/solar_scheduling.py:72
↓ 1 callersFunctiongenerate_sensor_data
Simulate raw sensor readings with occasional spikes.
examples/edge_mcu_sensor_processing.py:55
↓ 1 callersFunctionget_parslet_logger
Return a logger configured for Parslet CLI and library use. If ``rich`` is available, logs will be pretty-printed using ``RichHandler``; othe
parslet/utils/__init__.py:22
↓ 1 callersFunctionimport_dask_script
Convert a simple Dask workflow file to Parslet syntax.
parslet/compat/dask_adapter.py:92
↓ 1 callersFunctioninc
(x)
tests/test_benchmarks.py:5
↓ 1 callersFunctionis_vpn_active
Return True if a VPN-like network interface is detected.
parslet/utils/network_utils.py:32
↓ 1 callersFunctionload_csv
(path: str)
examples/csv_clean_classify/workflow.py:7
↓ 1 callersFunctionload_forms
(path: str, resources: Dict[str, bool])
use_cases/triage_tool.py:50
↓ 1 callersFunctionload_from_cache
Load a cached value for ``key`` if present.
parslet/core/cache.py:71
↓ 1 callersFunctionload_image
( image_path: str, resources: Dict[str, Optional[float]] )
examples/multi_ai_diagnosis.py:56
↓ 1 callersFunctionload_image
(path: str, resources: Dict[str, bool])
examples/mobile_edge_inference.py:61
↓ 1 callersFunctionload_image
Loads an image using Pillow and returns an Image object.
examples/image_filter.py:8
↓ 1 callersFunctionload_image
(path: str)
examples/photo_enhancer/workflow.py:17
↓ 1 callersFunctionload_jobs
(path: str, resources: Dict[str, bool])
use_cases/shared_hub_jobs.py:50
↓ 1 callersFunctionload_plugins
Load plugin modules from the plugins folder.
parslet/plugins/loader.py:12
↓ 1 callersFunctionload_power_log
(path: str, resources: Dict[str, bool])
use_cases/solar_scheduling.py:51
↓ 1 callersFunctionload_responses
( path: str, resources: Dict[str, bool] )
use_cases/offline_survey_flow.py:52
↓ 1 callersFunctionmain
(src: str = "./content")
use_cases/offline_edu_content_builder.py:101
↓ 1 callersFunctionmain
(queue_path: str = "jobs.json")
use_cases/shared_hub_jobs.py:83
↓ 1 callersFunctionmain
(log_path: str = "grid.log")
use_cases/smart_grid_maintenance.py:115
↓ 1 callersFunctionmain
(log_path: str = "tower_power.csv")
use_cases/telecom_power_monitor.py:126
↓ 1 callersFunctionmain
(log_path: str = "power.csv")
use_cases/solar_scheduling.py:93
↓ 1 callersFunctionmain
(forms_path: str = "forms.csv")
use_cases/triage_tool.py:99
↓ 1 callersFunctionmain
(image_folder: str = "./images")
use_cases/offline_crop_diagnosis.py:105
↓ 1 callersFunctionmain
(file_path: str = "survey.csv")
use_cases/offline_survey_flow.py:107
↓ 1 callersFunctionmain
Entry point used by the ``parslet`` console script.
parslet/main_cli.py:412
↓ 1 callersFunctionmain
()
examples/edge_mcu_sensor_processing.py:113
↓ 1 callersFunctionmain
(image_path: str | None = None)
examples/rad_pipeline.py:24
↓ 1 callersFunctionmain
(image_name: str = "scan.png")
examples/multi_ai_diagnosis.py:215
↓ 1 callersFunctionmain
r""" Defines the main workflow graph for this "Hello, Parslet!" example. This function is the designated entry point for the Parslet CLI. It
examples/hello.py:139
↓ 1 callersFunctionmain
(video_path: str)
examples/video_frames.py:46
↓ 1 callersFunctionmain
(image_path: str | None = None)
examples/mobile_edge_inference.py:116
↓ 1 callersFunctionmain
Defines the image filtering DAG and returns terminal futures.
examples/image_filter.py:64
↓ 1 callersFunctionmain
()
examples/photo_enhancer/workflow.py:33
↓ 1 callersFunctionmain
(image_path: str | None = None, out_dir: str = "rad_results")
examples/rad_parslet/rad_dag.py:14
↓ 1 callersFunctionmain
()
examples/csv_clean_classify/workflow.py:32
↓ 1 callersFunctionmake_stub_parsl
()
tests/test_parsl_bridge.py:23
↓ 1 callersFunctionmake_stub_parsl
()
tests/test_hybrid.py:18
↓ 1 callersFunctionmodel_a_inference
( img: Optional[np.ndarray], out_dir: Path, resources: Dict[str, Optional[float]], )
examples/multi_ai_diagnosis.py:96
↓ 1 callersFunctionmodel_b_inference
( img: Optional[np.ndarray], out_dir: Path, resources: Dict[str, Optional[float]], )
examples/multi_ai_diagnosis.py:136
↓ 1 callersFunctionnormalize_names
Ensure task names are unique by appending numeric suffixes. The function mutates the supplied ``IRTask`` instances and returns a new dictiona
parslet/core/ir.py:88
↓ 1 callersFunctionone
()
tests/test_parsl_bridge.py:111
↓ 1 callersFunctionone
()
tests/test_hybrid.py:90
↓ 1 callersMethodorder
Return tasks sorted by priority for the given power state.
parslet/core/policy.py:59
↓ 1 callersFunctionparse_log
( log_path: str, resources: Dict[str, bool] )
use_cases/smart_grid_maintenance.py:52
← previousnext →101–200 of 437, ranked by callers