openwpm.task_manager module

class openwpm.task_manager.TaskManager(manager_params_temp: ManagerParams, browser_params_temp: List[BrowserParams], structured_storage_provider: StructuredStorageProvider, unstructured_storage_provider: UnstructuredStorageProvider | None, logger_kwargs: Dict[Any, Any] = {})[source]

Bases: object

User-facing Class for interfacing with OpenWPM

The TaskManager spawns several child processes to run the automation tasks.
  • StorageController to receive data from across browsers and save it to the provided StorageProviders

  • MPLogger to aggregate logs across processes

  • BrowserManager processes to isolate Browsers in a separate process

browse(url: str, num_links: int = 2, sleep: int = 0, index: int | None = None, timeout: int = 60, reset: bool = False) None[source]

browse a website and visit <num_links> links on the page

close(relaxed: bool = True) None[source]

Execute shutdown procedure for TaskManager

execute_command_sequence(command_sequence: CommandSequence, index: int | None = None) None[source]

parses command type and issues command(s) to the proper browser <index> specifies the type of command this is: None -> first come, first serve int -> index of browser to send command to

get(url: str, index: int | None = None, timeout: int = 60, sleep: int = 0, reset: bool = False) None[source]

goes to a url