DRF_Template/backend/search_results/tasks.py

from celery import shared_task

from .models import SearchResult


@shared_task(
    autoretry_for=(Exception,), retry_kwargs={"max_retries": 0, "countdown": 5}
)
def create_search_result(title, link):
    if SearchResult.objects.filter(title=title, link=link).exists():
        return "SearchResult entry already exists"
    else:
        SearchResult.objects.create(title=title, link=link)
        return f"Created new SearchResult entry titled: {title}"
Update webdriver utility functions and add a sample celery task for scraping Google search 2024-09-24 16:08:28 +08:00			`from celery import shared_task`
Lint using autoflake and isort 2024-10-31 00:33:13 +08:00
Update webdriver utility functions and add a sample celery task for scraping Google search 2024-09-24 16:08:28 +08:00			`from .models import SearchResult`


Clean up docker-compose and run Black formatter over entire codebase 2024-10-30 22:09:58 +08:00			`@shared_task(`
			`autoretry_for=(Exception,), retry_kwargs={"max_retries": 0, "countdown": 5}`
			`)`
Update webdriver utility functions and add a sample celery task for scraping Google search 2024-09-24 16:08:28 +08:00			`def create_search_result(title, link):`
			`if SearchResult.objects.filter(title=title, link=link).exists():`
Clean up docker-compose and run Black formatter over entire codebase 2024-10-30 22:09:58 +08:00			`return "SearchResult entry already exists"`
Update webdriver utility functions and add a sample celery task for scraping Google search 2024-09-24 16:08:28 +08:00			`else:`
Clean up docker-compose and run Black formatter over entire codebase 2024-10-30 22:09:58 +08:00			`SearchResult.objects.create(title=title, link=link)`
Update webdriver utility functions and add a sample celery task for scraping Google search 2024-09-24 16:08:28 +08:00			`return f"Created new SearchResult entry titled: {title}"`