Skip to content

Commit

Permalink
delete commands and tasks for one usage (#1903)
Browse files Browse the repository at this point in the history
  • Loading branch information
da-maltsev authored Aug 25, 2023
1 parent d899f27 commit fbb557c
Show file tree
Hide file tree
Showing 7 changed files with 0 additions and 228 deletions.
38 changes: 0 additions & 38 deletions src/amocrm/management/commands/delete_duplicate_leads.py

This file was deleted.

17 changes: 0 additions & 17 deletions src/amocrm/management/commands/delete_free_leads.py

This file was deleted.

49 changes: 0 additions & 49 deletions src/amocrm/management/commands/export_amocrm_orders.py

This file was deleted.

22 changes: 0 additions & 22 deletions src/amocrm/management/commands/export_amocrm_users.py

This file was deleted.

21 changes: 0 additions & 21 deletions src/amocrm/management/commands/update_leads.py

This file was deleted.

42 changes: 0 additions & 42 deletions src/amocrm/services/orders/order_lead_deleter.py

This file was deleted.

39 changes: 0 additions & 39 deletions src/amocrm/tasks.py
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
from amocrm.services.contacts.contact_updater import AmoCRMContactUpdater
from amocrm.services.orders.order_lead_creator import AmoCRMOrderLeadCreator
from amocrm.services.orders.order_lead_creator import AmoCRMOrderLeadCreatorException
from amocrm.services.orders.order_lead_deleter import AmoCRMOrderLeadDeleter
from amocrm.services.orders.order_lead_to_course_linker import AmoCRMOrderLeadToCourseLinker
from amocrm.services.orders.order_lead_updater import AmoCRMOrderLeadUpdater
from amocrm.services.orders.order_pusher import AmoCRMOrderPusher
Expand Down Expand Up @@ -69,16 +68,6 @@ def push_order_to_amocrm(order_id: int) -> None:
AmoCRMOrderPusher(order=order)()


@celery.task(acks_late=True)
def delete_order_from_amocrm(order_id: int) -> None:
order = apps.get_model("orders.Order").objects.get(id=order_id)

if order.amocrm_lead is not None:
_delete_lead.delay(order_id=order_id)
if order.amocrm_transaction is not None:
_delete_transaction.delay(order_id=order_id)


@celery.task(
autoretry_for=[TransportError, AmoCRMTokenGetterException, AmoCRMClientException],
retry_kwargs={
Expand Down Expand Up @@ -262,34 +251,6 @@ def _push_transaction(order_id: int) -> int | None:
return AmoCRMOrderTransactionCreator(order=order)()


@celery.task(
autoretry_for=[TransportError, AmoCRMTokenGetterException, AmoCRMClientException],
retry_kwargs={
"max_retries": 10,
"countdown": 1,
},
rate_limit="3/s",
acks_late=True,
)
def _delete_lead(order_id: int) -> int:
order = apps.get_model("orders.Order").objects.get(id=order_id)
return AmoCRMOrderLeadDeleter(amocrm_lead=order.amocrm_lead)()


@celery.task(
autoretry_for=[TransportError, AmoCRMTokenGetterException, AmoCRMClientException],
retry_kwargs={
"max_retries": 10,
"countdown": 1,
},
rate_limit="3/s",
acks_late=True,
)
def _delete_transaction(order_id: int) -> None:
order = apps.get_model("orders.Order").objects.get(id=order_id)
return AmoCRMOrderTransactionDeleter(order=order)()


@celery.task(
autoretry_for=[TransportError, AmoCRMTokenGetterException, AmoCRMClientException],
retry_kwargs={
Expand Down

0 comments on commit fbb557c

Please sign in to comment.