3stack-software / celery-shoot Goto Github PK

Is there any way to specify ssl options for broker? Could not find any way to pass them.

Field name 'retries' is spelled wrong ('retires') in file protocol.js

• Celery Protocol
  • Support V2 Message protocol
  • Support RPC Backend
• Switch to amqplib http://www.squaremobius.net/amqp.node/channel_api.html
  • consider amqplib-stream
  • consider rabbot
  • consider bluebird

Hi @nathan-muir,

Thanks very much for creating this package. I managed to upgrade my install to Meteor 1.4.1.1 but now I find that when the method which calls the Celery task is run, Meteor becomes inaccessible and CPU usage spikes to 100%. The logs provide the below error. Oddly when checking Celery I can see that the task was received. Do you have any ideas?

Exception while invoking method 'start_robotics' { stack: undefined, source: 'method' }

[email protected] install /bundle/bundle/programs/server
node npm-rebuild.js

[email protected] install /bundle/bundle/programs/server
node npm-rebuild.js

[email protected] install /bundle/bundle/programs/server
[178.62.83.33]npm WARN [email protected] No description
npm WARN [email protected] No repository field.
npm WARN [email protected] No license field.
Error: Uncaught, unspecified "error" event. ([object Object])
at Consumer.emit (events.js:144:17)
at Consumer._channelClosed (/bundle/bundle/programs/server/npm/node_modules/meteor/3stack_celery-shoot/node_modules/celery-shoot/node_modules/amqp-coffee/bin/src/lib/Consumer.js:202:14)
at Consumer._channelClosed (/bundle/bundle/programs/server/npm/node_modules/meteor/3stack_celery-shoot/node_modules/celery-shoot/node_modules/amqp-coffee/bin/src/lib/Consumer.js:4:61)
at Consumer.Channel._onChannelMethod (/bundle/bundle/programs/server/npm/node_modules/meteor/3stack_celery-shoot/node_modules/celery-shoot/node_modules/amqp-coffee/bin/src/lib/Channel.js:349:16)
at Connection._onMethod (/bundle/bundle/programs/server/npm/node_modules/meteor/3stack_celery-shoot/node_modules/celery-shoot/node_modules/amqp-coffee/bin/src/lib/Connection.js:673:39)
at AMQPParser. (/bundle/bundle/programs/server/npm/node_modules/meteor/3stack_celery-shoot/node_modules/celery-shoot/node_modules/amqp-coffee/bin/src/lib/Connection.js:4:61)
at emitThree (events.js:97:13)
at AMQPParser.emit (events.js:175:7)
at AMQPParser.parseMethodFrame (/bundle/bundle/programs/server/npm/node_modules/meteor/3stack_celery-shoot/node_modules/celery-shoot/node_modules/amqp-coffee/bin/src/lib/AMQPParser.js:111:19)
at AMQPParser.frameEnd (/bundle/bundle/programs/server/npm/node_modules/meteor/3stack_celery-shoot/node_modules/celery-shoot/node_modules/amqp-coffee/bin/src/lib/AMQPParser.js:81:16)
/opt/meteord/run_app.sh: line 21: 8 Killed npm install --unsafe-perm
/opt/meteord/run_app.sh: line 21: 8 Killed npm install --unsafe-perm
[178.62.83.33]> node npm-rebuild.js
[178.62.83.33]/opt/meteord/run_app.sh: line 21: 8 Killed npm install --unsafe-perm

Much appreciated,

Wade

Hi,

I'm trying to use this in Meteor via 3stack:meteor-connect.

Celery is configured with:

app = Celery('jiraflow',
         broker='amqp://',
         backend='amqp://',
         include=['proj.tasks'])

Meteor is started with env CELERY_BROKER_URL="amqp://" meteor

Method is defined with:

runCeleryTask: function(left, right) {
    this.unblock();

    var task = Celery.createTask('proj.tasks.add');

    try {
        return Meteor.wrapAsync(task.invoke, task)([left, right]);
    } catch(e) {
        console.error(e);
    }
}

This is called from the client with: Meteor.apply("runCeleryTask", [3, 3], {wait: true}, function(err, result) { console.log("Done"); console.log(err); console.log(result); }).

This fails with an error in the logs:

W20150720-23:16:07.845(1)? (STDERR) AssertionError: false == true
W20150720-23:16:07.845(1)? (STDERR)     at Task.CeleryTask_sendMessage [as sendMessage] (/Users/maraspeli/.meteor/packages/3stack_celery-shoot/.4.0.1.1gklmv3++os+web.browser+web.cordova/npm/node_modules/celery-shoot/src/lib/Task.js:182:5)
W20150720-23:16:07.845(1)? (STDERR)     at Task.CeleryTask_invoke [as invoke] (/Users/maraspeli/.meteor/packages/3stack_celery-shoot/.4.0.1.1gklmv3++os+web.browser+web.cordova/npm/node_modules/celery-shoot/src/lib/Task.js:104:10)
W20150720-23:16:07.845(1)? (STDERR)     at packages/meteor/helpers.js:118:1
W20150720-23:16:07.845(1)? (STDERR)     at [object Object].Meteor.methods.runCeleryTask (server/query.import.js:41:55)
W20150720-23:16:07.845(1)? (STDERR)     at maybeAuditArgumentChecks (packages/ddp/livedata_server.js:1617:1)
W20150720-23:16:07.846(1)? (STDERR)     at packages/ddp/livedata_server.js:648:1
W20150720-23:16:07.846(1)? (STDERR)     at [object Object]._.extend.withValue (packages/meteor/dynamics_nodejs.js:56:1)
W20150720-23:16:07.846(1)? (STDERR)     at packages/ddp/livedata_server.js:647:1
W20150720-23:16:07.846(1)? (STDERR)     at [object Object]._.extend.withValue (packages/meteor/dynamics_nodejs.js:56:1)
W20150720-23:16:07.846(1)? (STDERR)     at [object Object]._.extend.protocol_handlers.method (packages/ddp/livedata_server.js:646:1)

I can't really understand what's going on :(

There doesn't seem to be docs explaining how to use it with Meteor, and 3stack:celery seems to be a different thing now? What am I missing?

Martin