Hey Jason, Sounds like Mike is asking for the same thing I was when first looking at Fantasm (quite some time ago now). I thought we'd came up with a patch that supported this? I'm not really sure where we left off with that.
Robert On Mon, Jun 6, 2011 at 13:04, Jason Collins <jason.a.coll...@gmail.com> wrote: > Currently, the fan_in aggregation rules cannot be customized; Fantasm > will aggregate anything that belongs to the same machine instance. > We're looking at some possible adjustments to this to allow developers > to specify their desired fan_in semantics. No ETA. > > For now, you could split your machine into two separate machines. The > first machine would simply iterate through your dates and kick off a > separate machine instance for each day (technically, in your case, > there's no need to build a continuation over the dates - the > documentation below will allow you to easily kick off multiple > machines in one call). The fan_in semantics will work over each > machine instance (date) separately. > > See context.spawn(): > http://code.google.com/p/fantasm/wiki/AdvancedConcepts#Spawning_New_Machines > > j > > On Jun 4, 8:08 am, Mike_W <myappengineer...@gmail.com> wrote: >> Hi, >> I use fantasm to aggregate daily transaction >> amounts.http://code.google.com/p/fantasm/wiki/GettingStarted >> >> This is how the current working state machine looks: >> >> Step-1) Class getCalendarDate -- returns a single date >> Step-2) Class QueryDB is a continuation class. -- returns transaction >> costs >> Step-3) Class Aggregate [Fan-in] -- Aggregates daily costs. >> >> Step-1 passes a date to step-2. >> Step-2 returns transaction details for the given date. >> Step-3 creates a DailyAggregate entity with the date as the entity >> name. >> >> This works great. >> _____________________________________________________________ >> >> What I want to do is make >> Step-1 getCalendarDate a continuation class >> >> I want to be able to aggregate a month's data in parallel. >> >> So for each date returned by Step-1, Step-2 kicks off a query [for >> this date]. >> This means that all 31 days in May are being queried simultaneously. >> >> How do I get ClassAggregate to fan in each day individually? >> >> Currently, when the fan in runs it aggregates all the data from Step-2 >> regardless which date is being queried. >> >> Regards >> Mike > > -- > You received this message because you are subscribed to the Google Groups > "Google App Engine" group. > To post to this group, send email to google-appengine@googlegroups.com. > To unsubscribe from this group, send email to > google-appengine+unsubscr...@googlegroups.com. > For more options, visit this group at > http://groups.google.com/group/google-appengine?hl=en. > > -- You received this message because you are subscribed to the Google Groups "Google App Engine" group. To post to this group, send email to google-appengine@googlegroups.com. To unsubscribe from this group, send email to google-appengine+unsubscr...@googlegroups.com. For more options, visit this group at http://groups.google.com/group/google-appengine?hl=en.
