| // Available variables: | |
| // - Machine | |
| // - interpret | |
| // - assign | |
| // - send | |
| // - sendParent | |
| // - spawn | |
| // - raise | |
| // - actions |
| // Available variables: | |
| // - Machine | |
| // - interpret | |
| // - assign | |
| // - send | |
| // - sendParent | |
| // - spawn | |
| // - raise | |
| // - actions |
| class DocumentFilterSet(FilterSet): | |
| period = django_filters.ChoiceFilter( | |
| choices=Periods.choices, | |
| label='Period', | |
| field_name='period', | |
| method='period_filter', | |
| ) | |
| def period_filter(self, queryset, name, value): | |
| if value: |
| # coding: utf-8 | |
| from __future__ import unicode_literals | |
| import os | |
| from pdfminer.pdfdocument import PDFEncryptionError | |
| from pdfminer.pdfinterp import PDFResourceManager, PDFPageInterpreter | |
| from pdfminer.converter import TextConverter | |
| from pdfminer.layout import LAParams | |
| from pdfminer.pdfpage import PDFPage | |
| from cStringIO import StringIO |
| # Adapted from: http://www.rabbitmq.com/install-debian.html | |
| if [ ! -f /etc/apt/sources.list.d/rabbitmq.list ] | |
| then | |
| echo "Installing RabbitMQ" | |
| echo 'deb http://www.rabbitmq.com/debian/ testing main' | sudo tee /etc/apt/sources.list.d/rabbitmq.list | |
| wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add - | |
| apt update | |
| apt -y install rabbitmq-server | |
| fi |
| from django.db.models.lookups import Lookup | |
| class DateRangeLowerInf(Lookup): | |
| """ | |
| Use like: | |
| `MyObject.objects.filter(date_range__lower_inf=True)` for infinity | |
| `MyObject.objects.filter(date_range__lower_inf=False)` for not infinity | |
| """ |
| class CustomTask(Task): | |
| def on_failure(self, exc, task_id, args, kwargs, einfo): | |
| info = '[{0}] failed: {1}'.format(task_id, exc) | |
| logger.exception(info, exc_info=exc) | |
| super(CustomTask, self).on_failure(exc, task_id, args, kwargs, einfo) | |
| def on_success(self, retval, task_id, args, kwargs): | |
| global app | |
| if app.is_warm_shutdown: | |
| app.consumer.connection._default_channel.do_restore = False |
| - name: Compute Vagrant latest version | |
| sudo: yes | |
| shell: wget -qO - https://dl.bintray.com/mitchellh/vagrant/|sed -n 's/.*href=\"\([^"]*\).*/\1/p'|grep x86_64\.deb|tail -1|cut -d'#' -f2 | |
| register: vagrant_file_name | |
| - name: Download Vagrant latest version | |
| shell: "wget https://dl.bintray.com/mitchellh/vagrant/{{ vagrant_file_name.stdout }} -O {{ vagrant_file_name.stdout }}" | |
| args: | |
| chdir: "./bootstrap/files" | |
| creates: "{{ vagrant_file_name.stdout }}" |
| - name: Download Telegram | |
| shell: "wget https://tdesktop.com/linux -O telegram.tar.xz" | |
| args: | |
| chdir: "./bootstrap/files" | |
| creates: "telegram.tar.xz" | |
| - name: Unarchive Telegram | |
| sudo: yes | |
| unarchive: src=telegram.tar.xz dest=/opt |
I'm going to cover a simple, but effective, utility for managing state and transitions (aka workflow). We often need to store the state (status) of a model and it should only be in one state at a time.
