Максим

В настройках celery добавляем периодические задания следующим образом

# Celery beat
app.conf.beat_schedule = {
    'scheduled': {
        'task': 'api.controllers.message.scheduled_message',
        'schedule': 60.0
    }
}

app.conf.timezone = 'UTC'

# scheduled_message оборачиваем в обычный task
@task()
def scheduled_message():
    pass

По поводу импорта вопрос остается актуальным и если кто знает в чем причина, буду благодарен за разъяснение.

Быстрая регистрация не позволяет взаимодействовать с api сервисов
Пример вк

1. Регистрация приложения Click me
   
2. Получение токена Get token
   
3. Теперь можно публиковать Post me
   

Изучив более подробно материалы о потоках, прислушавшись к советам, решена задача довольно таки просто.

Скрипт будет запускаться через manage.py, так не придется переписывать текущий функционал и при таком запуске будет создан отдельный процесс в системе, запустим в фоне с помощью surepvisord/systemd.

import threading
import time


def example(name ,event):
	i = 0
	while event.is_set():
		print('Thread: %s, %d', % (t1.name, i))
		i += 1
		time.sleep(10)


try:
	event = threading.Event()
	event.set()
	t1 = threading.Thread(target=example, args=('first', event))
	t1.start()
except KeyboardInterrupt:
	event.clear()
	t1.join()

Чтобы корректно завершать все это дело, напишем скрипт для вброса исключения, после чего event изменит флаг и потоки будут завершены.

Нашел причину, celery смотрит на второй питон

смотрим настройки celery
head -n 10 /usr/local/bin/celery
если указан
#!/usr/bin/python
собственно меняем на третий

Нашел причину, функция phone = validate_phone(data["phone"]), убирает + и поэтому сравнивался номер без +
Будет навык работы с чужим кодом)