python - Celery multi with queues set up not receiving tasks from django -

-

I am running my workers with the following command:

Celery- One map Multi-start 4-D debug -Q1: 3 qi1, qi2-q: 4 qi3

When I run the workers start very well < Blockquote>

active inspection of celery 

  result = series ( 
 Task1 .s (** kwargs) .set (queue = 'queue1'), task2.s (** kwargs) .set (queue = 'queue2')) ()   
 i results The result of shift as a result Get all the work IDs to be done and record them in the database for further investigation. When I release  
  task = asyncResult (task.id) task.status   
 I get 'pending' for each job, I Starting with the series. Celery logs are not receiving any functions. However, when I issue a   yes     
  celery item   
 > 
 I get a message that asyncrasult on my works actually removed from 1 queue. Has been removed from the station, which is shown as 'Pending' and the functions are never started. I use rabbitmq-server as the default configuration for my celestial config and it is really weird But in the other environment, the same code and commands present other results: workers also start but they get very much work and they have no problem Area is performed. Please think what could be a problem here.  
 ps When I start a worker in another way:  
  Celery - A map worker - Q Qi1, Qi2, Qi3-D debug   
 I still have to modify my chain when I started my execution of work and problem  
  .set (queue = 'queue1')   
 or queue2 or qi3  
 pps:  
 All my actions  
  @shared_task  < / Pre> 
 Decorator   P> 
 Is there at least one way to see that Nothing works (which I can remove by celery pure) are waiting on one line and waiting for queue name?   
 
 
 The celerary default settings should cover your case, so only one thing is that you have Consider some of the options in a manner that is mousing your queue, and consider commenting in this case ():  
     
  •  
      CELERY_QUEUES     
  •  
      CELERY_ROUTES    
  •  
      CELERY_DEFAULT_EXCHANGE    
  •  
      CELERY_DEFAULT_ROUTING_KEY    
  •  
      CELERY_DEFAULT_ROUTING_KEY    
     For your question, I think it is not that it is the complete answer, but you can do list of all active queues from RabbitMQ.  
     Using the cellar:  
      Celery - A project active inspection   
     using RabbitMQ:  
      rabbitmqadmin list queues vhost name node message message_stats.publish_details.rate

Comments

Post a Comment

Popular posts from this blog

ios - Adding an SKSpriteNode to SKScene from a child SKSpriteNode -

-
I have a SKScene where I am adding an SKSpriteNode I have subclassed the SKSpriteNode class to create this node. In the subclass I am defining some SKActions on Sprite. What do I want to do when the end of this phantom ends the SKAction sequence, then I add a new Prayer node to this scene. How is this possible. The following code is mine: The code for the sequence is that I'm running on the Scansprinitode subclass (TEMissileNode): - SKAction * moveDown = [SKAction moveToY: Self.position.y - 20 Duration: 0.2]; SKAction * animation = [SKAction animateWithTextures: textures timePerFrame: time / 7]; SKAction * moveMissileProjectile = [SKAction Moving: Pointoffscreen Term: Time]; SKAction * group = [SKAction group: @ [animation, movement projectile]]; SKAction * Sequence = [SKAction Sequence: @ [Hilldown, Group, [SKAction removalFromParent]]]; [Self run action: sequence]; From the main scene, I call those actions that execute these tasks TEMissileNode * missile = [tmissil...
Read more

Matlab transpose a table vector -

-
An embarrassing simple question seems to be, but how can I move a Matlab table vector? aTableT = aTable '; I tried a standard syntax for the simple interaction of a line vector to a line vector aTable : ATableT = reshape (aTable, 1, Height (aTable)); and aTableT = rot90 (aTable); According to the head, the last time table should work for table, see. However, I get this error code: Error type in using table / permit (line 396) Undefined function 'permute' for the input arguments. Error in rot 90 (line 29) b = magnitude (b, [2 1 3: ndims (a)]); NB: fliplr is not useful either pretty sure I have covered clear angles - any ideas? Thanks! Try changing your table into an array, move it, then back to a table In other words, try doing this: aTableArray = table2array (aTable); ATableT = array 2table (aTableArray. '); I have also read the document for rot90 , and it says that rot90 is definitely working for tables Do, and I find you...
Read more

c# - Textbox not clickable but editable -

-
I have a small form with 10 text boxes, I have set them in the correct tab order. I want them on my tab service I was wondering if there is a way to set the text box so that they can be selected for editing until they are tabbed. That is ... I do not want the end user to edit the text box to click on them, I just want to make them editable through tabu. this should do the trick public partial category poor text box: Text Box {Safe Override Zero WndProc (Ref: Message Message) {if (m.msg == (Int) WM.LBUTTONDOWN) {Return; // mount down events} base.WndProc (ref m); }} Window message enum can be found. How to do this without anherizing: text box : class EatMouseDown: netwindows {safe override zero WndProc (ref message message) {if (m.msg == (int) WM.LBUTTONDOWN) {return; } Base.WandProc (Ref M); }} Safe Override Zero Onload (EventEurge E) {base.OnLoad (e); How to do this without any part: left a clean part, whatever is important, this can be a buggy but it works R...
Read more