import sys
import os
sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..')))
from base.utils.funcs import send_request
from celery_tasks.celery import app

@app.task(queue='batches',rate_limit='20/m')
def send_batch_message(url: str, method: str, data: dict):
    send_request(url, method, data)