Initial commit

Author: agredyaev

.github/workflows/app-testing.yml

@@ -0,0 +1,31 @@
+name: build-and-test
+
+on:
+  push:
+    branches: [ main ]
+  pull_request:
+    branches: [ main ]
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        python-version: ["3.9", "3.10", "3.11"]
+    steps:
+    - uses: actions/checkout@v3
+    - name: Set up Python ${{ matrix.python-version }}
+      uses: actions/setup-python@v3
+      with:
+        python-version: ${{ matrix.python-version }}
+    - name: Install dependencies
+      run: |
+        python -m pip install --upgrade pip
+        pip install flake8 pytest
+        if [ -f requirements.txt ]; then pip install -r requirements.txt; fi
+    - name: Lint with flake8
+      run: |
+        # stop the build if there are Python syntax errors or undefined names
+        flake8 . --count --select=E9,F63,F7,F82 --show-source --statistics
+        # exit-zero treats all errors as warnings
+        flake8 . --count --exit-zero --max-complexity=10 --max-line-length=119 --statistics --config=setup.cfg

.gitignore

@@ -0,0 +1,4 @@
+
+.idea/
+__pycache__/
+*.pyc

README.md

@@ -0,0 +1,54 @@
+# Проектное задание второго спринта
+
+Спроектировать и реализовать планировщик задач для выполнения поступающих задач.
+
+## Описание задания
+
+**1. Описать реализацию класса `Scheduler`.**
+
+Условия и требования:
+- Планировщик одновременно может выполнять до 10 задач (дефолтное значение, может быть изменено).
+- Возможность добавить задачу в планировщик и запустить её в рамках ограничений планировщика и настроек, указанных в задаче.
+- При штатном завершении работы планировщик сохраняет статус выполняемых и ожидающих задач.
+- После рестарта восстанавливается последнее состояние и задачи продолжают выполняться.
+
+**2. Описать реализацию класса `Job`.**
+
+Условия и требования:
+- У задачи может быть указана длительность выполнения (опциональный параметр). Если параметр указан, то задача прекращает выполняться, если время выполнения превысило указанный параметр.
+- У задачи может быть указано время запуска (опциональный параметр). Если параметр указан, то задача стартует в указанный временной период.
+- У задачи может быть указан параметр количества рестартов (опциональный параметр). Если в ходе выполнения задачи произошёл сбой или задачи-зависимости не были выполнены, то задача будет перезапущена указанное количество раз. Если параметр не указан, то количество рестартов равно 0.
+- У задачи может быть указаны зависимости — задача или задачи, от которых зависит её выполнение (опциональный параметр). Если параметр указан, то задача не может стартовать до момента, пока не будут завершены задачи-зависимости.
+
+
+**3. Проверить работу планировщика на различных задачах.**
+
+Условия и требования:
+- работа с файловой системой: создание, удаление, изменение директорий и файлов;
+- работа с файлами: создание, чтение, запись;
+- работа с сетью: обработка ссылок (GET-запросы) и анализ полученного результата;
+- описать конвеер выполнения основной задачи минимум из 3 задач, зависящих друг от друга и выполняющихся последовательно друг за другом.
+
+## Требования к решению
+
+1. Используйте корутины и генераторы, изученные в теоретической части.
+2. Использование потоков и процессов не запрещено.
+3. Использование `asyncio` запрещено.
+4. Используйте встроенные библиотеки и модули языка.
+5. Используйте концепции ООП.
+6. Используйте аннотацию типов.
+7. Логируйте результаты действий.
+8. Предусмотрите обработку исключительных ситуаций.
+9. Приведите стиль кода в соответствие pep8, flake8, mypy.
+
+## Рекомендации к решению
+
+1. Покройте написанный код тестами.
+2. Для хранения статуса задач или планировщика используйте `.lock`-файлы и иные текстовые форматы — например, `txt` или `json`.
+3. Организуйте структуру хранения задач и/или их зависимостей в рамках отдельных директорий с определенным наименованием, используя `uid` или кастомный шаблон. Использование ссылок (`symlink`) не запрещено.
+4. Сигнатура описания классов может быть изменена под ваше усмотрение. Создавать дополнительные классы не запрещено.
+5. Используйте примитивы синхронизации, например, [Timer](https://docs.python.org/3/library/threading.html#timer-objects) или [Condition](https://docs.python.org/3/library/threading.html#condition-objects).
+6. По возможности, решение должно полностью строиться на использовании корутин.
+
+Схематично сервис представлен на [диаграмме](schema.png){target="_blank"}.
+![image](schema.png)

job.py

@@ -0,0 +1,12 @@
+class Job:
+    def __init__(self, start_at="", max_working_time=-1, tries=0, dependencies=[]):
+        pass
+
+    def run(self):
+        pass
+
+    def pause(self):
+        pass
+
+    def stop(self):
+        pass

scheduler.py

@@ -0,0 +1,15 @@
+class Scheduler:
+    def __init__(self, pool_size=10):
+        pass
+
+    def schedule(self, task):
+        pass
+
+    def run(self):
+        pass
+
+    def restart(self):
+        pass
+
+    def stop(self):
+        pass

schema.png

@@ -0,0 +1,12 @@
+[flake8]
+ignore =
+    W503,
+    F811
+exclude =
+    tests/,
+    */migrations/,
+    venv/,
+    env/
+per-file-ignores =
+    */settings.py:E501
+max-complexity = 10