def METHOD_NAME(self, organization_id, task, **kwargs):
    cache_key = f"organizationonboardingtask:{organization_id}:{task}"
    if cache.get(cache_key) is None:
        try:
            with transaction.atomic(router.db_for_write(OrganizationOnboardingTask)):
                self.create(organization_id=organization_id, task=task, **kwargs)
                return True
        except IntegrityError:
            pass
        # Store marker to prevent running all the time
        cache.set(cache_key, 1, 3600)
    return False