diff --git a/changedetectionio/content_fetchers/playwright.py b/changedetectionio/content_fetchers/playwright.py index 51231f048..6f4be0336 100644 --- a/changedetectionio/content_fetchers/playwright.py +++ b/changedetectionio/content_fetchers/playwright.py @@ -167,6 +167,7 @@ class fetcher(Fetcher): request_method=None, timeout=None, url=None, + watch_uuid=None, ): from playwright.async_api import async_playwright diff --git a/changedetectionio/content_fetchers/puppeteer.py b/changedetectionio/content_fetchers/puppeteer.py index 5d0c10478..98fdc6666 100644 --- a/changedetectionio/content_fetchers/puppeteer.py +++ b/changedetectionio/content_fetchers/puppeteer.py @@ -376,6 +376,7 @@ class fetcher(Fetcher): request_method=None, timeout=None, url=None, + watch_uuid=None, ): #@todo make update_worker async which could run any of these content_fetchers within memory and time constraints @@ -394,6 +395,7 @@ class fetcher(Fetcher): request_method=request_method, timeout=timeout, url=url, + watch_uuid=watch_uuid, ), timeout=max_time ) except asyncio.TimeoutError: diff --git a/changedetectionio/content_fetchers/requests.py b/changedetectionio/content_fetchers/requests.py index c53b14273..2ef9fe893 100644 --- a/changedetectionio/content_fetchers/requests.py +++ b/changedetectionio/content_fetchers/requests.py @@ -26,7 +26,9 @@ class fetcher(Fetcher): ignore_status_codes=False, current_include_filters=None, is_binary=False, - empty_pages_are_a_change=False): + empty_pages_are_a_change=False, + watch_uuid=None, + ): """Synchronous version of run - the original requests implementation""" import chardet @@ -129,6 +131,7 @@ class fetcher(Fetcher): request_method=None, timeout=None, url=None, + watch_uuid=None, ): """Async wrapper that runs the synchronous requests code in a thread pool""" @@ -146,7 +149,8 @@ class fetcher(Fetcher): ignore_status_codes=ignore_status_codes, current_include_filters=current_include_filters, is_binary=is_binary, - empty_pages_are_a_change=empty_pages_are_a_change + empty_pages_are_a_change=empty_pages_are_a_change, + watch_uuid=watch_uuid, ) ) diff --git a/changedetectionio/content_fetchers/webdriver_selenium.py b/changedetectionio/content_fetchers/webdriver_selenium.py index 28def8f94..603968293 100644 --- a/changedetectionio/content_fetchers/webdriver_selenium.py +++ b/changedetectionio/content_fetchers/webdriver_selenium.py @@ -71,6 +71,7 @@ class fetcher(Fetcher): request_method=None, timeout=None, url=None, + watch_uuid=None, ): import asyncio