Sum amount of concurrent pilots per time sample

[mturilli]

When measuring pilot concurrency, sampling returns all the timestamps within the sampling rate. For example:

session.concurrency(state=['PMGR_ACTIVE', ['DONE', 'CANCELED', 'FAILED']], sampling=60)
    timestamp   npilot
0   3.9303   1
1   4.4225   1
2   4.8275   1
3   5.3653   1
4   5.5524   1
5   5.6212   1
6   5.8381   1
7   6.0298   1
8   6.1350   1
9   6.7833   1
10  7.8033   1
11  63.9303  1
12  64.4225  1
13  64.8275  1
14  65.3653  2
15  65.5524  1
16  65.6212  1
17  65.8381  2
18  66.0298  2
19  66.1350  1
20  66.7833  2
21  67.8033  2
22  123.9303 1

When plotting this timeseries, it would be useful to have the total amount of entities in the specified state for the chosen time sample. For example:

1    60     11
2    120    16
...

[andre-merzky]

Hmm, this is actually what the sampling should do already, so this is a bug. thx!

[mturilli]

As a side note, this is done by the resample method in pandas:

>>> series
2000-01-01 00:00:00    0
2000-01-01 00:01:00    1
2000-01-01 00:02:00    2
2000-01-01 00:03:00    3
2000-01-01 00:04:00    4
2000-01-01 00:05:00    5
2000-01-01 00:06:00    6
2000-01-01 00:07:00    7
2000-01-01 00:08:00    8

>>> series.resample('3T', label='right', closed='right').sum()
2000-01-01 00:00:00     0
2000-01-01 00:03:00     6
2000-01-01 00:06:00    15
2000-01-01 00:09:00    15

[andre-merzky]

Sorry that this took so long to look into! To me it looks like the sample parameter to the session.concurrency() method does exactly what you are asking for. Like, I get reasonable output with different sample values for code like this:

    units = session.filter(etype='unit', inplace=False)
    conc = units.concurrency(state=[rp.AGENT_EXECUTING,
                                    rp.AGENT_STAGING_OUTPUT_PENDING], 
                                    sampling=1.0)   # sampling time in seconds

Is that what you mean?