hnykda

worker_1     | 20180625 15:52:42:urllib3.connectionpool:DEBUG http://es:9200 "POST /q4_2016/_doc/_update_by_query HTTP/1.1" 404 351
worker_1     | 20180625 15:52:42:elasticsearch:WARNING POST http://es:9200/q4_2016/_doc/_update_by_query [status:404 request:0.038s]
worker_1     | 20180625 15:52:42:elasticsearch:DEBUG > {"query":{"bool":{"should":[{"exists":{"field":"asked.test-project"}},{"exists":{"field":"test-project"}}],"minimum_should_match":1}},"script":{"source":"\n                        def fields = new ArrayList(ctx._source.keySet());\n                        if (params.fresh_sample_fields.containsAll(fields)){\n                            ctx.op = 'delete';\n                        } else {\n                            ctx._source.remove(params.project_id);\n                            ctx._source.asked.remove(params.project_id);\n                        }\n                    ","lang":"painless","params":{"not_exist_project_id":"invalid_project","project_id":"test-project","fresh_sample_fields":["a

hnykda

def migrate_data(apps, schema_editor):
    Tracker = apps.get_model('campaign', 'Tracker')
    Syncer = apps.get_model('campaign', 'Syncer')
    Key = apps.get_model('attribute', 'Key')
    for k in Key.objects.all():
        c = k.parent_campaign
        if c.campaign_type == 'Panel':
            new_camp = Syncer.objects.get(cid=c.cid)
        else:
            new_camp = Tracker.objects.get(cid=c.cid)

hnykda

Dec 02 11:20:45 think460s audit[2167]: ANOM_ABEND auid=1000 uid=1000 gid=1000 ses=1 pid=2167 comm="chromium" exe="/usr/lib/chromium/chromium" sig=4 res=1
Dec 02 11:20:45 think460s kernel: BUG: unable to handle kernel paging request at 0000000000020008
Dec 02 11:20:45 think460s kernel: PGD 0 P4D 0 
Dec 02 11:20:45 think460s kernel: Oops: 0000 [#1] PREEMPT SMP PTI
Dec 02 11:20:45 think460s kernel: CPU: 3 PID: 19433 Comm: rescuetime Tainted: G           OE     4.19.4-arch1-1-ARCH #1
Dec 02 11:20:45 think460s kernel: Hardware name: LENOVO 20FAS0FD07/20FAS0FD07, BIOS N1CET59W (1.27 ) 08/31/2017
Dec 02 11:20:45 think460s kernel: RIP: 0010:rb_next+0x27/0x50
Dec 02 11:20:45 think460s kernel: Code: 1f 40 00 48 8b 0f 48 39 cf 74 38 48 8b 47 08 48 85 c0 74 22 48 8b 50 10 48 85 d2 74 0c 48 89 d0 48 8b 50 10 48 85 d2 75 f4 c3 <48> 3b 79 08 75 12 48 8b 09 48 89 d7 48 83 e1 fc 48 89 ca 48 89 c8
Dec 02 11:20:45 think460s kernel: RSP: 0018:ffffbae98d4dbd40 EFLAGS: 00010206
Dec 02 11:20:45 think460s kernel: RAX: 00000000000200

hnykda

-- Logs begin at Sat 2017-10-07 14:26:40 CEST, end at Sun 2019-01-13 09:46:32 CET. --
Jan 13 09:45:51 think460s kernel: Linux version 4.20.0-arch1-1-ARCH (builduser@heftig-29859) (gcc version 8.2.1 20181127 (GCC)) #1 SMP PREEMPT Mon Dec 24 03:00:40 UTC 2018
Jan 13 09:45:51 think460s kernel: Command line: initrd=\initramfs-linux.img initrd=\intel-ucode.img root=PARTUUID=8d411a1d-fd6b-4916-b21f-f745a70a39d3 rw intel_iommu=off
Jan 13 09:45:51 think460s kernel: KERNEL supported cpus:
Jan 13 09:45:51 think460s kernel:   Intel GenuineIntel
Jan 13 09:45:51 think460s kernel:   AMD AuthenticAMD
Jan 13 09:45:51 think460s kernel:   Hygon HygonGenuine
Jan 13 09:45:51 think460s kernel:   Centaur CentaurHauls
Jan 13 09:45:51 think460s kernel: x86/fpu: Supporting XSAVE feature 0x001: 'x87 floating point registers'
Jan 13 09:45:51 think460s kernel: x86/fpu: Supporting XSAVE feature 0x002: 'SSE registers'

hnykda

import argparse
import datetime

import pandas as pd

def parse_args():
    parser = argparse.ArgumentParser()
    parser.add_argument('input', help='Input revolut export file')
    parser.add_argument('--output', default="rev2wall-{CURRENCY}-{TIMESTAMP}.csv", help='Input Revolut file')
    return parser.parse_args()

hnykda

from multiprocessing.pool import Pool
import os

def process_one_file(filename):
    print("processing ", filename)
    return filename


pool = Pool(4)
p = pool.imap_unordered(process_one_file, os.listdir(), chunksize=10000)

hnykda

louvre-d-# \d gallery_release
                                       Table "public.gallery_release"
   Column   |           Type           | Collation | Nullable |                   Default                   
------------+--------------------------+-----------+----------+---------------------------------------------
 id         | integer                  |           | not null | nextval('gallery_release_id_seq'::regclass)
 created_at | timestamp with time zone |           | not null | 
 updated_at | timestamp with time zone |           | not null | 
 label      | character varying(60)    |           | not null | 
 namespace  | character varying(20)    |           | not null | 
 creator_id | integer                  |           | not null | 

hnykda

apiVersion: batch/v1
kind: Job
metadata:
  labels:
    app: pyxecutor
    dan: test
  name: orchestra-core-q1-2019-20190420-080653
  namespace: pyxecspawner-jobs
spec:
  backoffLimit: 1

hnykda

import inspect
from typing import Callable, List, Union, Any, Dict

Variable = str
Value = Union[str, int, float]
Condition = List[Value]
DataElement = Dict[Any, Any]


class BaseCommand:

hnykda

{
  "log": {
    "version": "1.2",
    "creator": {
      "name": "WebInspector",
      "version": "537.36"
    },
    "pages": [
      {
        "startedDateTime": "2019-05-09T14:31:22.936Z",