Skip to content

Instantly share code, notes, and snippets.

const pipelineState = require('state').pipeline;
const fs = require('fs');
const log = require('log');
const moment = require('moment');
const config = require('config');
module.exports = (done) => {
log.info('[STEP][NMS] Dumping backup infos');
const pipelineState = require('state').pipeline;
const request = require('superagent');
const config = require('config');
const log = require('log');
const _ = require('lodash');
const async = require('async');
const CHUNK_SIZE = 100;
const INTERVAL = 100;
const pipelineState = require('state').pipeline;
const config = require('config');
const utils = require('utils');
const glob = require('glob');
const csvParser = require('csv-parse/lib/sync');
const fs = require('fs');
const log = require('log');
const moment = require('moment');
const request = require('superagent');
const _ = require('lodash');
export type Step = {
stepId: number,
name: string,
code: string,
orderNumber: number,
};
export type Stage = {
stageId: number,
name: string,
/* @flow */
import type { Message, SuccessMessage, ErrorMessage, Schedule } from './types';
//eslint-disable-next-line
export const schedulingMessage = (operation: string, targetNodeId: number, payload: Schedule): Message => ({
cmd: `schedule::${operation}`,
args: [targetNodeId, payload],
});
  • On shutdown:
    • node announces shut down started SHUTTING_DOWN;

Messages

backup::progress

{
 cmd: 'backup::progress',
def page_meta
[
build_meta(name: 'WT.z_cg_type'
]
end
def build_meta(name:, property: nil, content:)
{
name: name,
property: property,
[
{
"title": "FOR AUTHORS & REFEREES",
"url": null,
"view_all_text": null,
"links": [
{
"text": "Guide to Authors",
"url": "/authors/index.html"
},
#spot
%h3
= link_to "Birra di Natale", birre_natale_path
%ul{id: "nav_section", class: "nav_graph"}
- @beers.each do |beer|
%li{class: beer_class(beer.slug)}
= link_to(beer.name, birra_path(beer.slug))
= image_tag("/assets/#{Settings.beers["#{beer.slug}"].image}", border: 0)